onestep 0.3.21

No project description provided

---

仅需一步，轻松实现分布式异步任务。

Brokers

• MemoryBroker
• CronBroker
• WebHookBroker
• RabbitMQBroker
• RedisBroker
• KafkaBroker

example

from onestep import step, WebHookBroker


# 对外提供一个webhook接口，接收外部的消息
@step(from_broker=WebHookBroker(path="/push"))
def waiting_messages(message):
    print("收到消息：", message)


if __name__ == '__main__':
    step.start(block=True)

from onestep import step, CronBroker


# 每3秒触发一次任务
@step(from_broker=CronBroker("* * * * * */3", a=1))
def cron_task(message):
    assert message.body == {"a": 1}
    return message


if __name__ == '__main__':
    step.start(block=True)

更多例子请参阅：examples