如何从回调中访问信息

Question

我只想知道如何从回调中获取数据。

import pika


def callback(channel, method, properties, body):
    print(method.get_body())
    print(method.get_properties())
    channel.basic_ack(delivery_tag=method.delivery_tag)

def on_open(connection):
    connection.channel(on_open_callback=on_channel_open)


def on_channel_open(channel):
    channel.basic_consume(on_message_callback = callback, queue='q1')
    channel.basic_consume(on_message_callback = callback, queue='q2')


credentials = pika.PlainCredentials('user', 'password', erase_on_connect=False)
params = pika.ConnectionParameters("localhost", 5672, '/', credentials)

connection = pika.SelectConnection(parameters=params,
                                   on_open_callback=on_open)

try:
    connection.ioloop.start()
except KeyboardInterrupt:
    connection.close()

    connection.ioloop.start()

回调中两个打印行的输出是：

<class 'pika.spec.Basic.Deliver'>
<Basic.Deliver(['consumer_tag=ctag1.2607da3f5f9f4e5592991a16cc0aca6e', 'delivery_tag=1', 'exchange=gatekeeper', 'redelivered=True', 'routing_key=laa'])>

如何提取“routing_key”？查看源代码让我相信method.get_properties() 会起作用，但它没有。

Answer 1

虽然记录不充分，callback 函数将使用 4 个参数调用：

• 您使用的频道
• Method 实例（在本例中为 Deliver 实例）
• BasicProperties 实例
• 身体 (bytes)

Deliver 实例将有一个名为routing_key 的属性。所以你的函数可能看起来像这样：

def callback(channel, method, properties, body):
    print(method.get_body())
    print(method.get_properties())
    print(method.routing_key)
    channel.basic_ack(delivery_tag=method.delivery_tag)

PS。将调用回调的参数与here 中描述的相同，它们已实际记录在案。