Feat cli

[mic1on]

# example.py

from onestep import step, WebHookBroker


@step(from_broker=WebHookBroker(path="/push"))
def waiting_messages(message):
    print("message：", message)

you can use onestep command to start

$ onestep example

log output:

[2023-11-25 22:08:03,719] [onestep] [INFO] OneStep 0.3.5 is start up.
[2023-11-25 22:08:03,720] [onestep.onestep] [DEBUG] start group [all]
[2023-11-25 22:08:03,720] [onestep.onestep] [DEBUG] started: consumer=<ThreadWorker waiting_messages>
[2023-11-25 22:08:03,926] [onestep.broker.webhook] [DEBUG] WebHookBroker: 0.0.0.0:8090/push

then, you can send a message to webhook:

$ curl -X POST -H "Content-Type: application/json" -d '{"a": 1}' http://localhost:8090/push

and we will receive message:

message： {'body': {'a': 1}, 'extra': {'task_id': 'd7d10d60-33e9-4be7-ad41-fdee8401ce33', 'publish_time': 1700921346.82, 'failure_count': 0}}