object detection: config

opencv-yolo/deployment/start-local.sh

 #!/bin/bash
 export API_HOST=http://40.73.45.56:9009 
 export RABBITMQ_URI=amqp://ilabservice:iLabServiceOps123456@40.73.43.214:5672
-export MQTT_HOST=evcloudsvc.ilabservice.cloud
+#export MQTT_HOST=evcloudsvc.ilabservice.cloud
 export MQTT_PORT=11883
 export MQTT_USER=admin
 export MQTT_PASSWORD=vJ3zHqWrHbrqxVMT

opencv-yolo/web/test_pubaitask.py

+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()