一 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不能用的字符 ！！！

类似这种文件结构：