xxl-jobs 的python客户端实现

使用pyxxl可以方便的把Python写的方法注册到XXL-JOB中,使用XXL-JOB-ADMIN管理Python定时任务和周期任务

实现原理：通过XXL-JOB提供的RESTful API接口进行对接

注意！！！如果用同步的方法，请查看下面同步任务注意事项。

已经支持的功能

执行器注册到job-admin
task注册，类似于flask路由装饰器的用法
任务的管理（支持在界面上取消，发起等操作，任务完成后会回调admin）
所有阻塞策略的支持
异步支持（推荐）
job-admin上查看日志

已经测试过的XXL-JOB版本

3.3.2,2.4.0,2.3.0,2.2.0

如遇到不兼容的情况请issue告诉我XXL-JOB版本和对应的问题我会尽量适配

如何使用

pip install pyxxl

# 如果日志需要写入redis
pip install "pyxxl[redis]"

# 如果需要从.env加载配置
pip install "pyxxl[dotenv]"

# 安装所有功能
pip install "pyxxl[all]"

import asyncio

from pyxxl import ExecutorConfig, PyxxlRunner

config = ExecutorConfig(
    xxl_admin_baseurl="http://localhost:8080/xxl-job-admin/api/",
    executor_app_name="xxl-job-executor-sample"
)

app = PyxxlRunner(config)

@app.register(name="demoJobHandler")
async def test_task():
    await asyncio.sleep(5)
    return "成功..."

# 如果你代码里面没有实现全异步，请使用同步函数，不然会阻塞其他任务
@app.register(name="xxxxx")
def test_task3():
    return "成功3"


app.run_executor()

更多示例和接口文档请参考 PYXXL文档，具体代码在example文件夹下面

如果executor服务无法直连xxl-admin，请参考PYXXL配置修改executor_listen_host

监控指标

pip install "pyxxl[metrics]"

安装metrics扩展后，执行器会自动加载prometheus的指标监控功能

访问地址为: http://executor_listen_host:executor_listen_port/metrics

同步任务注意事项

同步任务会放到线程池中运行，无法正确接受cancel信号和timeout配置

如果需要使用同步任务并且无法控制（预料）里面执行时间，又需要进行超时和cancel功能的，需要接受pyxxl发出的cancel_event，当该cancel_event被设置时需要中断任务，下面是一个案例:

...

@app.register(name="sync_func")
def sync_loop_demo():
    # 如果同步任务里面有循环，为了支持cancel操作，必须每次都判断g.cancel_event.
    task_params_list = []
    while not g.cancel_event.is_set() and task_parasm_list:
        params = task_params_list.pop()
        time.sleep(3)
    return "ok"

# 如下代码会造成线程池里的线程被永远占用，timeout cancel全部不生效
@app.register(name="sync_func2")
def sync_loop_demo2():
    while True:
        time.sleep(3) # 模拟你运行的任务
    return "ok"

其他

由于种种3.9之后才加入的语法与特性，减少开发与适配成本，计划后续版本不再适配Python3.9以下版本，0.3.0最后一个支持Python3.8的版本
访问xxl-admin接口时支持从环境变量读取代理(列如HTTP_PROXY)

已知问题

界面上显示的执行时间其实是任务回调的时间，而不是真正开始的时间.这是XXL-JOB的bug，pyxxl这边已经传了正确的执行时间过去，XXL-JOB没有按预期解析直接取了当前时间
日志的实时拉取进度有问题，暂时不好解决，进行中的任务刷新整个页面

Star History

开发人员

下面是开发人员如何快捷的搭建开发调试环境

启动xxl的调度中心

./init_dev_env.sh

http://127.0.0.1:8080/xxl-job-admin/

admin/123456

启动执行器

uv sync --all-extras
# 修改app.py中相关的配置信息,然后启动
python example/executor_app.py

Metadata

Release files for pyxxl 0.4.8

For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.

Source distribution (sdist)

Source distribution for pyxxl 0.4.8
File	Size	Uploaded
pyxxl-0.4.8.tar.gz	549.3 kB	Jul 31, 2026	Details

Built distribution (wheel)

Table of built distributions (wheels) for pyxxl 0.4.8
File	Interpreter	ABI	Platform	Reset
pyxxl-0.4.8-py3-none-any.whl 50.0 kB Jul 31, 2026	Python 3	none	any	Details

Total release size: 599.3 kB

Release files / pyxxl-0.4.8.tar.gz

Download URL	pyxxl-0.4.8.tar.gz
Size	549.3 kB
Tags	Source
SHA-256 checksum How to use checksums	`110a67aa91d8da87bf90563089143fbaa4e1ed0687e904da78f3ce1a63e1e1b0`
BLAKE2b-256 checksum How to use checksums	`b3eb7b625375fee57125008944c44c783623b2b60724735797d16e0736a4e7e9`
Upload date	Jul 31, 2026
Uploaded using Trusted Publishing? What is trusted publishing?	No
Uploaded via	`twine/7.0.0 CPython/3.13.14`

Release files / pyxxl-0.4.8-py3-none-any.whl

Download URL	pyxxl-0.4.8-py3-none-any.whl
Size	50.0 kB
Tags	Python 3
SHA-256 checksum How to use checksums	`ca9dbded407c0eda3ba7be4443f8c7074be58ddbc979e4f526cc64f981455c63`
BLAKE2b-256 checksum How to use checksums	`81c606218856f9e456b24ed6c0a6b852e86fe505ece648b21ec9c70b8b88a229`
Upload date	Jul 31, 2026
Uploaded using Trusted Publishing? What is trusted publishing?	No
Uploaded via	`twine/7.0.0 CPython/3.13.14`