启动脚本

BaseDataMaintenance/maintenance/dataflow_mq.py

@@ -627,7 +627,7 @@ class Dataflow_ActivteMQ_extract(Dataflow_extract):
             #         log("%s--%s"%(str(resp.status_code),resp.content.decode("utf8")))
             #         all_done = -3
             _to_ack = False
-            if all_done>0 and len(_extract.getProperties().get(document_extract2_extract_json,""))<=2 or len(_extract.getProperties().get(document_extract2_industry_json,""))<=2:
+            if all_done>0 and len(_extract.getProperties().get(document_extract2_extract_json,""))<=2:
                 all_done = -4
             try:
                 if all_done!=1:

BaseDataMaintenance/readme/start.md

@@ -5,55 +5,45 @@
 #121.46.18.113:11022启动同步定时器
 #切换目录
 cd /data/python
-#激活环境
-source activate py37
 #先关闭
 ps -ef | grep start_dataflow_init | grep -v grep | cut -c 9-16| xargs kill -9
 #启动
-nohup python BaseDataMaintenance/start_dataflow_init.py >> flow_init.log &
+nohup /data/anaconda3/envs/py37/bin/python BaseDataMaintenance/start_dataflow_init.py >> flow_init.log &
 
 
 #121.46.18.113:11022启动要素提取定时器
 #切换目录
 cd /data/python
-#激活环境
-source activate py37
 #先关闭
 ps -ef | grep start_dataflow_extract | grep -v grep | cut -c 9-16| xargs kill -9
 #启动
-nohup python BaseDataMaintenance/start_dataflow_extract.py >> flow_extract.log &
+nohup /data/anaconda3/envs/py37/bin/python BaseDataMaintenance/start_dataflow_extract.py >> flow_extract.log &
 
 #121.46.18.113:11022启动监控程序
 #切换目录
 cd /data/python
-#激活环境
-source activate py37
 #先关闭
 ps -ef | grep start_dataflow_monitor | grep -v grep | cut -c 9-16| xargs kill -9
 #启动
-nohup python BaseDataMaintenance/start_dataflow_monitor.py >> flow_monitor.log &
+nohup /data/anaconda3/envs/py37/bin/python BaseDataMaintenance/start_dataflow_monitor.py >> flow_monitor.log &
 
 
 ===================================
 #121.46.18.113:19022启动监控程序
 #切换目录
 cd /data/python
-#激活环境
-source activate py37
 #先关闭
 ps -ef | grep start_dataflow_attach_monitor | grep -v grep | cut -c 9-16| xargs kill -9
 #启动
-nohup python BaseDataMaintenance/start_dataflow_attach_monitor.py >> flow_monitor.log &
+nohup /data/anaconda3/envs/py37/bin/python BaseDataMaintenance/start_dataflow_attach_monitor.py >> flow_monitor.log &
 
 #121.46.18.113:19022启动附件识别程序
 #切换目录
 cd /data/python
-#激活环境
-source activate py37
 #先关闭
 ps -ef | grep start_dataflow_attachment | grep -v grep | cut -c 9-16| xargs kill -9
 #启动
-nohup python BaseDataMaintenance/start_dataflow_attachment.py >> flow_attachment.log &
+nohup /data/anaconda3/envs/py37/bin/python BaseDataMaintenance/start_dataflow_attachment.py >> flow_attachment.log &
 
 #47.98.57.0:
 #项目路径/mnt/python/BaseDataMaintenance