关于python:nameko-队列名的构成规则

evt-imdb_produce_service-to_refresh--imdb_consumer_service.refresh 队列举例

投递音讯

dispatch(
    'imdb_produce_service',
    'to_refresh',
    message.json(ensure_ascii=False)
)

生产音讯

class ImdbRefreshService:
    name = 'imdb_consumer_service'

    @event_handler(
        source_service='imdb_produce_service',
        event_type='to_refresh',
        requeue_on_error=True)
    def refresh(self, payload: str) -> None:
        message = Message.parse_raw(payload)

所以,nameko 队列的命名规定是: evt-{source_service_name}-{event_type}--{dst_service_name}.{dst_class_func_name}

评论

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

这个站点使用 Akismet 来减少垃圾评论。了解你的评论数据如何被处理