Faust for Python: how to start worker to run hello world

2.1k Views Asked by At

In Spyder, i am trying the Hello World application from the official Faust website:

import faust

app = faust.App(
    'hello-world',
    broker='kafka://localhost:9092',
    value_serializer='raw',
)

greetings_topic = app.topic('greetings')

@app.agent(greetings_topic)
async def greet(greetings):
    async for greeting in greetings:
        print(greeting)

I start Zookeeper and Kafka (kafka works in Spyder with Consumer/Producer example)

I am stuck at this stage to start a worker

$ faust -A hello_world worker -l info

i tried this in the command line but $ faust is not recognized; i tried in the Python interpreter as well but doesnt work (I was not expecting any of this to work).

I read about daeamonization so i imagine this has something to do with that but once again i could run the Kafka consumer/producer example just with python interpreter.

thank you

0

There are 0 best solutions below