object detection: rabbitmq support for task

opencv-motion-detect/deployment/evdaemon.service

@@ -16,6 +16,7 @@ Environment="LD_LIBRARY_PATH=/root/work/opencv-pocs/opencv-motion-detect/vendor/
 ExecStart=/root/work/opencv-pocs/opencv-motion-detect/evdaemon
 WorkingDirectory=/root/work/opencv-pocs/opencv-motion-detect
 Restart=always
+RestartSec=3
 StartLimitIntervalSec=0
 StandardOutput=syslog
 StandardError=syslog

opencv-yolo/web/web_rabbit.py

@@ -357,6 +357,17 @@ def video_analysis(data):
         mc.username_pw_set(username=MQTT_USER,password=MQTT_PASSWORD)
     mc.connect(MQTT_HOST, MQTT_PORT)
     mc.publish('video.ai/v1.0/result', json.dumps(ret), qos=1)
+    print("connecting rabbitmq {}".format(RABBITMQ_URI))
+    # rabbitmq
+    if RABBITMQ_URI:
+        parameters = pika.URLParameters(RABBITMQ_URI)
+        connection = pika.BlockingConnection(parameters)
+        rabChanResult = connection.channel()
+        if AI_EXCHANGE:
+            rabChanResult.exchange_declare(exchange=AI_EXCHANGE, exchange_type="direct")
+        rabChanResult.basic_publish(exchange =AI_EXCHANGE,routing_key=AI_QUEUE_RESULT,body=json.dumps(ret),
+            properties=pika.BasicProperties(delivery_mode = 2))
+        rabChanResult.close()
     try:
         os.system('rm -fr ' + downloadDir)
     except Exception as e: