Skip to main content
Help us improve Python packaging – donate today!

kafka simple using

Project Description

消息队列,基于 redis 或者 beanstalk

You can install pysubman from PyPI with

$ pip install pysubman

Version update

  • 1.20.1.4 处理线程异常
  • 1.20.1.3 修改 redis rpop to brpop
  • 1.20.1.1 添加 redis 消息默认前缀 mq:
  • 1.20.1.0 添加 redis 消息队列, <C-c> 终止处理
  • 1.10.4 添加 Producer put 返回值
  • 1.10.4 添加 beanstalkd;修改 Customer Producer 接口
  • 1.10.2 去掉 logging
  • 1.10.0 将 kafka 迁移到 beanstalk

Getting Started

Producer

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

import json
import time
from pysubman.redis.client import Client

client = Client(host="127.0.0.1:6379:5")
message = json.dumps({
    "type": "linkedin",
    "time": time.time(),
})
client.publish("oauth:linkedin", message)

Customer

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

from pysubman.redis.client import Client
from pysubman.redis.service import Service
from pysubman.redis.subscribe import Subscriber

services = Service()


@services.C("oauth:linkedin")
def handler_email_job(body):
    logging.warn(("body", body))


def main():
    Subscriber(Client(host="127.0.0.1:6379:5")).subscribe(services)


if __name__ == "__main__":
    main()

TODO

  • 添加 tcp 链接超时处理

Support

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

Release history Release notifications

This version
History Node

1.20.1.4

History Node

1.20.1.3

History Node

1.20.1.2

History Node

1.20.1.1

History Node

1.20.1.0

History Node

1.10.7

History Node

1.10.6

History Node

1.10.5

History Node

1.10.4

History Node

1.10.3

History Node

1.10.2

History Node

1.10.1

History Node

1.10.0

History Node

1.0.6

History Node

1.0.5

History Node

1.0.4

History Node

1.0.3

History Node

1.0.1

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Filename, size & hash SHA256 hash help File type Python version Upload date
pysubman-1.20.1.4.tar.gz (9.0 kB) Copy SHA256 hash SHA256 Source None Dec 8, 2015

Supported by

Elastic Elastic Search Pingdom Pingdom Monitoring Google Google BigQuery Sentry Sentry Error logging CloudAMQP CloudAMQP RabbitMQ AWS AWS Cloud computing Fastly Fastly CDN DigiCert DigiCert EV certificate StatusPage StatusPage Status page