提交 d4273563 authored 作者: blu's avatar blu

nop

上级 b91ccff3
...@@ -279,7 +279,7 @@ def take_task(task): ...@@ -279,7 +279,7 @@ def take_task(task):
ret['data'] = taskValidator.errors ret['data'] = taskValidator.errors
else: else:
# process # process
task["region"] = getRegionConfig(task['cameraId']) task["region"] = None #getRegionConfig(task['cameraId'])
print("got region for ipc {}: {}".format(task['cameraId'], json.dumps(task["region"]))) print("got region for ipc {}: {}".format(task['cameraId'], json.dumps(task["region"])))
video_analysis.apply_async(args=[task]) video_analysis.apply_async(args=[task])
print(json.dumps(ret)) print(json.dumps(ret))
...@@ -370,6 +370,7 @@ def video_analysis(data): ...@@ -370,6 +370,7 @@ def video_analysis(data):
except Exception as e: except Exception as e:
ret["code"] = 1 ret["code"] = 1
ret["msg"] = "failed to save file: " + str(e) ret["msg"] = "failed to save file: " + str(e)
os.system("rm -fr " + downloadDir)
# pub msg # pub msg
if MQTT_HOST: if MQTT_HOST:
mc = mqtt.Client((MQTT_CID + '-pub') if MQTT_CID else "vamqtt-pub") mc = mqtt.Client((MQTT_CID + '-pub') if MQTT_CID else "vamqtt-pub")
...@@ -399,4 +400,4 @@ if __name__ == '__main__': ...@@ -399,4 +400,4 @@ if __name__ == '__main__':
mq = VAMMQTTClient(take_task) mq = VAMMQTTClient(take_task)
app.config['mc'] = mq.client app.config['mc'] = mq.client
app.run(host='0.0.0.0', port='5000') app.run(host='0.0.0.0', port='5000')
\ No newline at end of file
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论