converter.py 文件源码

def enqueue_flight_snippet(flight_snippet):
    """Add items from the flight_dictionary to rabbitmq queue as json strings"""
    channel.basic_publish(exchange='',
                          routing_key=queue_name,
                          body=flight_snippet,
                          properties=pika.BasicProperties(delivery_mode=2)  # make message persistent
                          )


# this function reads a dictionary of a flight snapshot and returns a different and easier to work with dictionary