共计 475 个字符,预计需要花费 2 分钟才能阅读完成。
以 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}
正文完