messaging.py 文件源码

def publish(body):
    """ Publishing message.

    Args:
        body (str): message.
    """
    connection = pika.BlockingConnection(
        pika.ConnectionParameters(host=rpc_host))
    channel = connection.channel()

    channel.basic_publish(exchange='',
                          routing_key=CONF['os_info']['REGION_NAME'],
                          body=body)