python的浮士德:如何启动worker来运行helloworld

bzzcjhmw  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(302)

在spyder中,我正在尝试faust官方网站上的hello world应用程序:

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)

我开始zookeeper和kafka(kafka在spyder中的作品,以消费者/制作人为例)
我正处于创业的阶段

$ faust -A hello_world worker -l info

我在命令行中尝试过这个,但是 $ faust 不被认可;我也尝试了python解释器,但没有成功(我不希望这一切都能成功)。
我读过关于daeamonization的文章,所以我认为这与此有关,但是我可以再次使用python解释器运行kafka consumer/producer示例。
谢谢您

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题