pysubman 1.10.1

kafka simple using

消息队列，基于 beanstalk

You can install pysubman from PyPI with

$ pip install pysubman

Version update

• 1.10.0 将 kafka 迁移到 beanstalk

Getting Started

Producer

#!/usr/bin/env python
# coding=utf-8

import time
import logging
logging.basicConfig(level=logging.DEBUG)
import pysubman


class EMAIL(object):
    Tube = "t-101"
    Topic = "EMAIL"
    Info = [
        ("TemplateUrl", "%s"),
        ("Params", "%s"),
    ]

client = pysubman.Producer(beanstalkd_host="192.168.0.23:11300")

while True:
    now_time = time.time()
    client.put(EMAIL, "baidu.com", "chaungwang: {}".format(now_time))
    time.sleep(1)

Customer

#!/usr/bin/env python
# coding=utf-8

import logging
import pysubman
logging.basicConfig(level=logging.DEBUG)

service = pysubman.Service()


@service.C(["EMAIL", "EMAIL.SEND_TEMPLATE"])
def handler_email_job(body):
    logging.warn(("body", body))


def main():
    consumer = pysubman.Consumer(
        beanstalkd_host="192.168.0.23:11300",
        services=service).tube("t-101")
    consumer.run()


if __name__ == "__main__":
    main()

TODO

• 根据不同的环境，用户选择不同的slave
• add retry connecting(bug: interactive_timeout)
• add is_auto_allocation(Automatic Identification master and slave)
• Thread Safety

Support

If you need help using pymysqlslave or have found a bug, please open a github issue.