# pip install -i https://mirrors.aliyun.com/pypi/simple/ pyssdbimport pyssdbc = 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,不要使用线程！