背景

记录网页访问的PV与UV，其中PV需要统计每十五分种内的数据，

比如9：00-9：15为一个统计区间，可以获取指定日期指定时间

的片的数据

统一配置

import redis

client = redis.Redis(host="192.168.200.128", port=6379, db=0)

统计PV

import datetime

# 获取时间片

def get_time_interval():

slices = datetime.datetime.now().strftime("%Y%m%d:%H:%M").split(':')

slices[2] = str(int(slices[2]) / 15) # 针对分钟取模

return ':'.join(slices)

# 访问则加1

def increment_page_pv(page_id):

res = client.hincrby(get_time_interval(), page_id, 1)

print(res)

# 获取指定网页指定时间片的PV

def get_page_pv(time_interval, page_id):

return client.hget(time_interval, page_id)

if __name__ == '__main__':

page_id = 'page100'

for i in range(100):

increment_page_pv(page_id)

time_inter = get_time_interval()

print(get_page_pv(time_inter, page_id))

统计UV-使用集合(当数据量特别大时，内存会增加，不合适)

import datetime

def get_today():

return datetime.datetime.now().strftime("%Y%m%d")

def add_uv(account_id):

name = 'uv:{}'.format(get_today())

client.sadd(name, account_id)

def get_uv(date):

name = 'uv:{}'.format(date)

return client.scard(name)

if __name__ == '__main__':

date = get_today()

for i in range(100):

ac_id = 'test_{}'.format(i)

add_uv(ac_id)

print(get_uv(date))

UV统计-使用hyperloglog

import datetime

def get_today():

return datetime.datetime.now().strftime("%Y%m%d")

def add_uv(account_id):

name = 'uv_hyper:{}'.format(get_today())

client.pfadd(name, account_id)

def get_uv(date):

name = 'uv_hyper:{}'.format(date)

return client.pfcount(name)

if __name__ == '__main__':

date = get_today()

for i in range(100):

ac_id = 'test_{}'.format(i)

add_uv(ac_id)

print(get_uv(date))