| 1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556 |
- import time, datetime
- import json
- import traceback
- from apscheduler.schedulers.blocking import BlockingScheduler
- import pandas as pd
- from ZlwlAlgosCommon.utils.ProUtils import *
- from ZlwlAlgosCommon.service.iotp.IotpAlgoService import IotpAlgoService
- cur_env = 'prd' # 设置运行环境
- app_path = "/home/shouxueqi/projects/zlwl-algos/" # 设置相对路径
- log_base_path = f"{os.path.dirname(os.path.abspath(__file__))}/log" # 设置日志路径
- app_name = "schedule" # 应用名, 建议与topic的后缀相同
- sysUtils = SysUtils(cur_env, app_path)
- mysqlUtils = MysqlUtils()
- mysql_iotp_params = sysUtils.get_cf_param('mysql-iotp')
- mysql_iotp_engine, mysql_iotp_Session= mysqlUtils.get_mysql_engine(mysql_iotp_params)
- mysql_kw_params = sysUtils.get_cf_param('mysql-algo')
- mysql_kw_engine, mysql_kw_Session= mysqlUtils.get_mysql_engine(mysql_kw_params)
- redis_params = sysUtils.get_cf_param('redis')
- redisUtils = RedisUtils()
- rc = redisUtils.get_redis_conncect(redis_params)
- kafka_params = sysUtils.get_cf_param('kafka')
- kafkaUtils = KafkaUtils()
- kafka_producer = kafkaUtils.get_kafka_producer(kafka_params, client_id="test")
- logger_main = sysUtils.get_logger(app_name, log_base_path)
- # # mysql
- mysql_algo_params = sysUtils.get_cf_param('mysql-algo')
- mysqlUtils = MysqlUtils()
- mysql_algo_engine, mysql_algo_Session= mysqlUtils.get_mysql_engine(mysql_algo_params)
- mysql_algo_conn = mysql_algo_engine.connect()
- df_snpk_list = pd.read_sql("select sn, imei,pack_model,device_cell_type,scrap_status from t_device where organ_code='001001'", mysql_algo_conn)
- df_snpk_list=df_snpk_list[df_snpk_list['scrap_status']<4]
- df_snpk_list=df_snpk_list.rename(columns={'pack_model':'pack_code'})
- print(len(df_snpk_list))
- fault_info_ing=pd.read_sql("select * from algo_all_fault_info_ing", mysql_algo_conn)
- print(len(fault_info_ing))
- x=list(set(fault_info_ing['sn']))
- print(len(x))
- # fault_info_ing_after=pd.merge(fault_info_ing,df_snpk_list,on=['sn'],how='inner')
- # print(len(fault_info_ing_after))
- # # main()
- # task_day_1_sxq_test = task_day_1_1_sxq_test
- # group_id_task_day_1_sxq_test = group_task_day_1_sxq_test
|
