在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示例。
谢谢您
暂无答案!
目前还没有任何答案,快来回答吧!