def publish_message(rabbit_config):
def publish(
exchange, payload, routing_key=None, serializer="json", **kwargs
):
conn = Connection(rabbit_config[AMQP_URI_CONFIG_KEY])
with connections[conn].acquire(block=True) as connection:
exchange.maybe_bind(connection)
with producers[conn].acquire(block=True) as producer:
producer.publish(
payload,
exchange=exchange,
routing_key=routing_key,
serializer=serializer,
**kwargs
)
return publish
评论列表
文章目录