Tweets hashtags real-time processing with Faust - Agent

agent.py

hashtags_topic = app.topic('hashtags', value_type=str)
hashtags_counts_table = app.Table('hashtags_counts', default=int)

@app.agent(hashtags_topic)
async def hashtags_counter(hashtags) -> None:
    async for hashtag in hashtags:  # type: str
        hashtags_counts_table[hashtag] += 1