import pika, os

RABBITMQ_URI = os.getenv("RABBITMQ_URI", "amqp://ilabservice:iLabServiceOps123456@40.73.43.214:5672/")
RABBITMQ_TOPIC = os.getenv("RABBITMQ_TOPIC", "*.camera.model")
RABBITMQ_EXHANGE = os.getenv("RABBITMQ_EXHANGE", "video")
AI_QUEUE_TASK = os.getenv('AI_TASK', 'videoai.v1.task')
AI_QUEUE_RESULT = os.getenv('AI_RESULT', 'videoai.v1.result')
AI_EXCHANGE = os.getenv('AI_XHG', 'videoai')



print("connecting rabbitmq {}".format(RABBITMQ_URI))
if RABBITMQ_URI:
    parameters = pika.URLParameters(RABBITMQ_URI)
    connection = pika.BlockingConnection(parameters)
    rabChanTask = connection.channel()
    # if AI_EXCHANGE:
    #     rabChanTask.exchange_declare(exchange=AI_EXCHANGE, exchange_type="direct")
    # rabChanTask.queue_bind(exchange=AI_EXCHANGE,
    #                     queue=AI_QUEUE_TASK, routing_key=AI_QUEUE_TASK)
    rabChanTask.basic_publish(exchange =AI_EXCHANGE,routing_key=AI_QUEUE_TASK,body='{"cameraId": "D72154040", "endTime": 1577267418999, "image": "http://evcloudsvc.ilabservice.cloud/video/D72154040/1550143347000-1577267418999/firstFrame.jpg", "length": 260, "startTime": 1550143347000, "video": "http://evcloudsvc.ilabservice.cloud/video/D72154040/1550143347000-1577267418999/1550143347000-1577267418999.mp4"}')
    rabChanTask.close()