zoukankan      html  css  js  c++  java
  • 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,不要使用线程!
  • 相关阅读:
    做前端的一些小工具
    分析几种编程语言对JSON的支持程度
    注册中心eureka
    搭建分布式配置中心
    接口幂等性
    分布式限流
    服务容错解决方案
    微服务架构认知
    gateWay
    JWT鉴权
  • 原文地址:https://www.cnblogs.com/littlehb/p/9295857.html
Copyright © 2011-2022 走看看