则将最后N分钟的集合交集在一起即可

发布时间：2021-08-01 00:14 来源：网络整理阅读：74 作者：chengxuyonghu 栏目：云计算欢迎投稿：712375056

print "%s: %s" % (key, info[key])

#求并集并将结果返回

7. 应用场景 – 实时用户统计

#zset 有序set

>>> r.hgetall('users:jdoe')

for x in minutes])

r.expire('c3',10) #让数据10秒后过期说实话我不太明白么意思
r.sdiff('s1','s2','s3')
>>> r.sadd('circle:soccer:InterMilan','user:Guo')

user_key = 'user-activity/%s' % user_id
r.sinterstore('s3','s1','s2')

{'phone': '1555313940', 'name': 'John Doe', 'visits': '1', 'email': 'John@test.com'}
print 'existes:',r.exists('a')
print 'list ltrim :',r.ltrim('b',start=0,end=3) #只留从0到3四位
>>> r.save() #执行“检查点”操作，将数据写回磁盘。保存时阻塞
每当有一个页面点击，则使用INCR增加点击数即可。
# 求不同
# 判断set中一个对象是否存在
print 'randomkey:',r.randomkey()
1L

>>> r.get('guo')

1L
# -------------------------------------------
34636
r.dbsize() #数据库中多少个条数
import redis

wget https://pypi.python.org/packages/source/r/redis/redis-2.9.1.tar.gz
执行pipe = r.pipeline(transaction=False)可以禁用这一特性。
print 'decr:',r.decr('a')
《Redis Cookbook》对这个经典场景进行详细描述。假定我们对一系列页面需要记录点击次数。例如论坛的每个帖子都要记录点击次数，而点击次数比回帖的次数的多得多。如果使用关系数据库来存储点击，可能存在大量的行级锁争用。所以，点击数的增加使用redis的INCR命令最好不过了。
ONLINE_LAST_MINUTES = 5
>>> r.smembers('circle:game:lol')

#如果你想设置一个递减的整数 please:
r.srandmember('s1')
在社交网站中，每一个圈子(circle)都有自己的用户群。通过圈子可以找到有共同特征（比如某一体育活动、游戏、电影等爱好者）的人。当一个用户加入一个或几个圈子后，系统可以向这个用户推荐圈子中的人。
<SHELL># apt-get install python-pip
页面载入的时候则可直接获取这个值
2 . 简单的redis操作
>>> r.get ("visit:1237:totals")
# 哦对了它是支持批量操作的

# 集合(set)操作

p.set(user_key, now) #记录用户的标记时间
当有大量类型文档的对象，文档的内容都不一样时，（即“表”没有固定的列），可以使用hash来表达。

# 这可是个大工程

# 在s1中有，但在s2和s3中都没有的数

print 'list len:',r.llen('b')

r = redis.Redis(host=’localhost’, port=6379, db=0)

# 移动数据去2数据库
print '\ndbsize: %s' % r.dbsize()

return redis.sunion(['online-users/%d' % (current - x) #取ONLINE_LAST_MINUTES分钟对应集合的交集

# 查数据库大小
r.sismember('s','a')

>>> r.set("visit:1237:totals",34634)

['name', 'email', 'phone', 'visits']

>>> r.keys()

redis> smembers circle:jdoe:family

print 'r['']:',r['c1']

我们定义这样两个圈子,并加入一些圈子成员。

set(['user:Guo', 'user:leo'])

# 它有四种类型： string(key,value)、list(序列)、set(集合)、zset(有序集合,多了一个顺序属性)
# 塞数据

可以使用集合运算来得到几个圈子的共同成员：

>>> p.sadd('faz','baz')

>>> r.sadd('circle:soccer:InterMilan','user:Levis')

3. pipeline操作

# 它是两头通的
r.sunion('s1','s2')

......

#或者
#添加, 数量, 自加1,取数据,按照积分(范围)取数据,删除,取积分
# 排序
#--------------------------------

# 看一个set对象
Running setup.py (path:/tmp/pip_build_root/redis/setup.py) egg_info for package redis
Successfully installed redis
r.push('b','gg')
>>> r.incr("visit:1237:totals")
expires = now + (app.config['ONLINE_LAST_MINUTES'] * 60) + 10 #过期的UNIX时间戳
#'zadd', 'zcard', 'zincr', 'zrange', 'zrangebyscore', 'zrem', 'zscore'
[True, 1, 1]
p.sadd(all_users_key, user_id) #将用户id插入到包含分钟信息的集合中
r.delete(‘test’) #删除这个key
1
1

# 删数据 1是删除成功 0和None是没这个东西
4. 应用场景 – 页面点击数
#求交集并将结果赋值
>>> p.execute()

now = int(time.time()) #当前的UNIX时间戳
>>> r['guo']
r.smembers('s3')
easy_install redis
print 'delete:',r.delete('c1','c2')
print 'getset:',r.getset('c2','jj')

# 塞入

>>> r.hset('users:jdoe', 'email', 'John@test.com')
# head 属性控制是不是从另一头塞

r['test'] = ‘test’ #或者可以r.set(‘test’, ‘test’) 设置key
#如果你想设置一个递增的整数每执行一次它自加1：
r.exists(‘test’) #检测这个key是否存在

<SHELL># pip install --proxy=http://172.1.2.6:8080 redis
# 求交集
'34636'
也可以使用easy_install的方式来安装：
>>> r.hset('users:jdoe', 'name', "John Doe")
p.expireat(user_key, expires)
if last_active is None:
# 其他
# 列出一批出来
return datetime.utcfromtimestamp(int(last_active))
1
r.ttl('c3') #看剩余过期时间不存在返回-1
r.sunionstore('ss','s1','s2','s3')

Cleaning up...

#r.lastsave('a') # 取最后一次save时间

print "ping %s" % r.ping()

r.push('b','hh')
#或者同时取一批

>>> r.sunion('circle:game:lol', 'circle:soccer:InterMilan')

>>> r.set('guo','shuai')

>>> r.hincrby('users:jdoe', 'visits', 1)

5. 使用hash类型保存多样化对象

6. 应用场景 – 社交圈子数据

r.sadd('s2','a')

from redis import Redis

r.sdiffstore('s4','s1','s2')# 这个你懂的

# 求并集

>>> p.set('hello','redis')

print '-'*20

# 修剪列表

# 取个随机数
r.rename('a','c3') #呃.改名

current = int(time.time()) // 60

>>> r.flushdb() #清空r中的所有数据

>>> r.get('hello')

>>> r.sinter('circle:game:lol', 'circle:soccer:InterMilan')

['guo']

#--------------------------------

minutes = xrange(app.config['ONLINE_LAST_MINUTES'])

或者直接编译安装：

>>> r.hkeys('users:jdoe')

r.sadd('s', 'a')
#获得某一圈子的成员
'redis'
'shuai'
默认的情况下，管道里执行的命令可以保证执行的原子性，
set(['user:Guo', 'user:debugo', 'user:leo'])
>>> p.set('hello','redis').p.sadd('faz','baz').incr('num').execute()
# 看连接
print 'mget:',r.mget('c1','c2')
print 'incr:',r.incr('a')

# 取出一位
>>> r = redis.Redis(host='localhost',port=6379,db=0)

p = redis.pipeline()
print 'keys:',r.keys('c*')
1
>>> r.sadd('circle:game:lol','user:debugo')
cd redis-2.9.1
34635
>>> r.sadd('circle:game:lol','user:leo')
True
True
def mark_online(user_id): #将一个用户标记为online
redis = Redis()
# 塞数据
print 'get:',r.get('a')
# 看长度

1L
set(['user:Levis', 'user:Guo', 'user:debugo', 'user:leo'])
>>> r.sadd('circle:soccer:InterMilan','user:leo')
>>> r.incr("visit:1237:totals")
r.set('c2','bar')
# string操作

>>> r.get('guo');

# 分别对应

管道（pipeline）是redis在提供单个请求中缓冲多条服务器命令的基类的子类。它通过减少服务器-客户端之间反复的TCP数据库包，从而大大提高了执行批量命令的功能。

#r.save('a') # 存数据

return None

#又或者你只想随机取一个：

p.expireat(all_users_key, expires) #设定集合的过期时间为UNIX的时间戳

#-------------------------------------

>>> p = r.pipeline() --创建一个管道

r.scard('s')

tar xvzf redis-2.9.1.tar.gz

print 'list lrange:',r.lrange('b',start=0,end=-1)

'shuai'

>>> r.hset('users:jdoe', 'phone', '1555313940')

info = r.info()

redis连接实例是线程安全的，可以直接将redis连接实例设置为一个全局变量，直接使用。如果需要另一个Redis实例（or Redis数据库）时，就需要重新创建redis连接实例来获取一个新的连接。同理，python的redis没有实现select命令。

#--------------------------------------------
print 'list index 0:',r.lindex('b',0)

last_active = redis.get('user-activity/%s' % user_id) #如果获取不到，则返回None

#r.shutdown() #关闭所有客户端，停掉所有服务，退出服务器

免责声明：本站发布的内容（图片、视频和文字）以原创、来自本网站内容采集于网络互联网转载等其它媒体和分享为主，内容观点不代表本网站立场，如侵犯了原作者的版权，请告知一经查实，将立刻删除涉嫌侵权内容，联系我们QQ:712375056，同时欢迎投稿传递力量。

其他博客 51CTO博客

上一篇新闻：
上一篇：所以选型的风险就增大了很多

下一篇新闻：
下一篇：计划真赶不上变化吗

云主机8折虚拟主机6折

红包可用于（云服务器、高防服务器、裸金属服务器、高防IP、云数据库、CDN加速）购买和续费

最新资讯

杉岩数据统一存储平台Sand

如何检查搬瓦工SSH端口被封

流利说实战经验！多语言U

个人选购虚拟主机的5个技巧

阿里云服务器CentOS 6.3下快速

申请电子邮箱域名要注意什

虚拟主机不稳定影响网站吗

域名主机记录

为什么我的企业邮箱总是发

极光KVM-美西CN2，CUVIP，香港

相关推荐

2021年全国优秀数据中心点亮

怎么自己搭建一个网站？搭

#投稿#华纳云：云服务器年付

美国HostEase虚拟主机7月新推

linux服务器如何查看防火墙

站群服务器我们必须注意哪

racknerd四月闪购,3核2GB内存

DigiCert和GlobalSign的区别，哪

SugarHosts无限流量云服务器上

Webhosting24：日本东京NTT直连

相关标签

51CTO博客其他博客

则将最后N分钟的集合交集在一起即可

特网科技产品

解决方案

帮助与支持

其他链接

联系我们