python使用ssdb的队列,用于替换canal+rabbitmq

时间:2018-07-11 19:59:04   收藏:0   阅读:1308
# pip install -i https://mirrors.aliyun.com/pypi/simple/ pyssdb

import pyssdb

c = pyssdb.Client(172.17.91.21,8888)
queueName=mysqlreplaction_test
# 清空一下队列
c.qclear(queueName)

c.qpush(queueName,1)
c.qpush(queueName,2)
c.qpush(queueName,3)
c.qpush(queueName,4)
c.qpush(queueName,5)
# 队列长度
l=c.qsize(queueName)
print(队列长度:+str(l))

# 只读取前3 个,不清除
list1=c.qslice(queueName,0,2)
print(list1)

# 清除掉前3个
c.qtrim_front(queueName,3)

# 再尝试读取3个
list1=c.qslice(queueName,0,2)
print(list1)

l=c.qsize(queueName)
print(队列长度:+str(l))
c.disconnect()
print(已成功断开链接!)

#   这是两个python脚本 ,一个是从mysql binlog中读取信息,导入到ssdb list中,另一个是监控ssdb的list,将数据批量上传到kafka,不要使用线程!

 

评论(0
© 2014 mamicode.com 版权所有 京ICP备13008772号-2  联系我们:gaon5@hotmail.com
迷上了代码!