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

# 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,不要使用线程！