commit

src/python2/pjibot/merge.py

@@ -18,7 +18,7 @@ key2 = 'data/'
 key3 = 'data_merge/'
 key4 = 'data_parse/'
 
-sleep_time = 5  # 每多少秒扫描一次
+sleep_time = 60  # 每多少秒扫描一次
 compress_way = Compression.BZ2
 
 

src/python2/pjibot/pcd-pjibot.py

@@ -9,12 +9,11 @@ import logging
 
 path1 = '/mnt/disk001/dcl_data_process/src/python2/pjibot/'
 path2 = '/mnt/disk001/dcl_data_process/src/python2/pjibot/resource/'
-logging.basicConfig(filename=path1 + 'log/pjibot_pcd.log', level=logging.INFO,
+logging.basicConfig(filename=path1 + 'log/pcd.log', level=logging.INFO,
                     format='%(asctime)s - %(levelname)s - %(message)s')
 
 key1 = 'pjibot/'
-path1 = '/root/'
-sleep_time = 2  # 每多少秒扫描一次
+sleep_time = 60  # 每多少秒扫描一次
 
 
 def parse_to_pcd_mp4(merged_bag_file_path, parse_prefix2, local_parse_dir, local_delete_list):
@@ -73,10 +72,8 @@ if __name__ == '__main__':
     # bucket = oss2.Bucket(auth, cname, 'open-bucket', is_cname=True)
     endpoint = 'oss-cn-beijing-gqzl-d01-a.ops.gqzl-cloud.com'
     bucket = oss2.Bucket(auth, endpoint, 'pji-bucket1')
-    turn = 1
     while True:
-        logging.info("当前轮次: %s" % str(turn))
-        turn += 1
+        logging.info("开始新一轮扫描")
         try:
             local_delete_list = []
             oss_delete_list = []