dam

Python Stream Processing minimalistic toolkit

⚠️ WARNING ⚠️

This repo is highly experimental and it's not recommended for production use.

The interface may change at any time during initial development.

Still not published to pypi.

importasynciofromdamimportApp, Topicloop=asyncio.get_event_loop()
asyncdefhello_world(stream):
asyncforvalueinstream:
print(value.value)
topics= [
Topic("test-topic-worker", hello_world)
]
streamapp=App(topics=topics, broker="kafka:0.0.0.0:29092")
whileTrue:
# This should be any other workerloop.run_until_complete(streamapp.run())

Example

• simple-kafka-consumer

Usage

1. Clone repository
2. Run poetry install
3. Write apps inside example folder (for now)