Edacious an Event Derive Architecture framework
Project description
Edacious an Event Derive Architecture framework
Implementing an EDA usually requires a queue mechanism. Currently support Redis streams and Amazon Web Services SQS.
Event must be a dict that contain data to be processed.
Every event must have an event type (str) attribute, reserve key is event-type
.
To process an event the event type has to be associated to one or more event handlers.
Event handler is a function that receive an event (dict) and process it, here is an example for running event listener based on Amazon Web Services SQS.
from edacious.sqs import EventListener
SQS_URL = 'https://sqs.my-region.amazonaws.com/123456789012/my-app-sqs'
@event_handler(event_type='hello-world')
def my_handler(event: dict):
print(event)
if __name__ == '__main__':
listener = EventListener(sqs_url=SQS_URL, visibility_timeout=60, max_messages_to_fetch=10)
listener.set_seconds_to_wait(seconds=2.5)
listener.run()
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
edacious-0.0.11.tar.gz
(4.7 kB
view hashes)
Built Distribution
Close
Hashes for edacious-0.0.11-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 91938f576a343a1d80b6ecd75ef07d8d3a589d7f6aaca963cd3ba85d1595c404 |
|
MD5 | 4b7ac84fbae90b0634d9f188e300cdbe |
|
BLAKE2b-256 | 4742b7d66dc5f31286eebe4901754b1c1eb8edb1f04cbb1024b4d666f7e89f21 |