一 Python 调度器传参
1.1 按位置传参
注意调 args 设置好之后,使用 scheduler.start() 启动调度器。
# 设置调度器
scheduler = BlockingScheduler() # 采用阻塞的方式
# 分拆上传数据模块,上传算法使用的数据
scheduler.add_job(func=up_load_data, trigger=CronTrigger(minute=f"*/{settings.interval_min}",second=20, timezone=local_tz), args=[param_config])
scheduler.start()
1.2 使用参数传参
使用 kwargs 进行传参。
scheduler = BlockingScheduler() # 采用阻塞的方式
scheduler.add_job(func=up_load_amend_data,trigger=CronTrigger(minute="*/{}".format(1), second=20, timezone="Asia/Shanghai"),args=(param_config,),kwargs={'upload_model_id': 'rawwaterv3_forecast'})scheduler.start()
二 在Python 里面创建 包或者库
需要再 包文件里面放 __init__ 文件,但是注意 文件名不能是Python不能用的字符 !!!
类似这种文件结构: