initial

Ex.py

@@ -19,8 +19,7 @@ if __name__ == '__main__':
                                        "失败信息：" + str(traceback.print_exc()))
                                        "失败信息：" + str(traceback.print_exc()))
         elif sys.argv[1] == 'del_sku':
         elif sys.argv[1] == 'del_sku':
             try:
             try:
-                # ExLySku.del_sku()
-                pass
+                ExLySku.del_sku()
             except:
             except:
                 MsgHandler.send_dd_msg("【Mongo数据删除任务】 失败\n" +
                 MsgHandler.send_dd_msg("【Mongo数据删除任务】 失败\n" +
                                        "失败信息：" + str(traceback.print_exc()))
                                        "失败信息：" + str(traceback.print_exc()))

extract/ex_ly_sku.py

@@ -28,12 +28,9 @@ class ExLySku(Base):
         index = 0
         index = 0
 
 
         # 筛选条件
         # 筛选条件
-        query = {"time": {"$gte": DateHandler.date_time(0), "$lte": DateHandler.date_time(-1)}}
-        print(query)
+        query = {"time": {"$gte": DateHandler.date_time(1), "$lte": DateHandler.date_time(0)}}
 
 
         while True:
         while True:
-            if index > 2000:
-                break
             # 获取数据
             # 获取数据
             result = table.find(query).skip(skip).limit(limit)
             result = table.find(query).skip(skip).limit(limit)
             # 数据读取完毕，跳出循环
             # 数据读取完毕，跳出循环