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