没有项目描述
celery-skinos的Python项目详细描述
芹菜皮
芹菜集成定制消费者。
用法
fromskinos.custom_consumerimportCustomConsumer
定义新交换
使用名称和绑定密钥（始终是主题）定义了新的交换。 exchange名称必须是unic
# add_exchange(str, str) -> ExchangeCustomConsumer.add_exchange('test',"test.*.*")
定义新任务
定义新的消息处理程序
装饰采用3个参数：
- 交换名称（必须定义）
- 队列名称（必须定义）
- 队列绑定键
但有这个原型：(str, Message) -> Any
body是有效载荷msg是消息对象（kombu.transport.myamqp.message）
# consumer(str, str, str) -> Callable[[str, Message], Any]@CustomConsumer.consumer('test','test.test','test.test.*')defcoucou(body,msg):print('payload content : {}'.format(body))print('message object content : {}'.format(msg))
为芹菜整合打造消费者
建立消费者自身。以前的所有方法都只是此生成的预配置。 这需要一个论点，那就是芹菜应用程序。
# build(Celery) -> NoneCustomConsumer.build(app)
添加岗哨管理员
对于芹菜项目，你必须正常地启动岗哨。 然后斯基诺斯就能捕捉到异常并派哨兵来。
将sentry设置为true并将raise设置为false（即：如果发生错误，错误不会重新引发，而是被忽略） 如果不使用，则默认值为false和false
# with_sentry(bool, bool) -> Tuple(bool, bool)
CustomConsumer.with_sentry(False, False)
芹菜
正常食用芹菜
欢迎加入QQ群-->： 979659372
