message_queue.py 文件源码

def get_connection():
    # ????
    parameters = pika.ConnectionParameters(RABBIT_MQ_HOST, RABBIT_MQ_PORT)
    # ????????
    connection = pika.BlockingConnection(parameters)

    return connection