from apscheduler.executors.pool import ThreadPoolExecutor, ProcessPoolExecutor
from apscheduler.jobstores.redis import RedisJobStore
from redis import ConnectionPool


# celery 配置信息
class Config():
    # 配置信息具体意思请自行搜索，所需额外配置信息都可以写入该类中
    BROKER_URL = 'redis://192.168.245.4:6379/5'  # 指定中间件 Broker
    CELERY_RESULT_BACKEND = 'redis://192.168.245.4:6379/5'  # 指定 Backend
    CELERY_TIMEZONE = 'Asia/Shanghai'  # 指定时区，默认是 UTC

    # 指定导入的任务模块
    CELERY_IMPORTS = (
        # 格式 文件夹.文件
        'job_main',  # 主任务模块
    )


pool = ConnectionPool.from_url('redis://192.168.245.4:6379/5')
jobstores = {
    'redis': RedisJobStore(connection_pool=pool),  # 用redis作backend
}

# apscheduler 配置信息
executors = {
    'default': ThreadPoolExecutor(10),  # 默认线程数
    'processpool': ProcessPoolExecutor(3)  # 默认进程
}