{"repo":"taskiq-python/taskiq-faststream","free":true,"listed":false,"github":"https://github.com/taskiq-python/taskiq-faststream","clone":"git clone https://github.com/taskiq-python/taskiq-faststream.git","description":"FastStream - Taskiq integration to provide you with a great scheduling feature","language":"Python","stars":61,"topics":["asyncio","faststream","kafka","nats","python","rabbitmq","taskiq","taskiq-broker"],"license":"MIT","category":"data-pipelines","readme_excerpt":"Taskiq - FastStream --- The current package is just a wrapper for FastStream objects to make them compatible with Taskiq library. The main goal of it - provide FastStream with a great Taskiq tasks scheduling feature. Installation If you already have FastStream project to interact with your Message Broker, you can add scheduling to it by installing just a taskiq-faststream If you starting with a clear project, you can specify taskiq-faststream broker by the following distributions: For OpenTelemetry distributed tracing support: Usage The package gives you two classes: AppWrapper and BrokerWrapper These are just containers for the related FastStream objects to make them taskiq -compatible To create scheduling tasks for your broker, just wrap it to BrokerWrapper and use it like a regular taskiq Broker. To run the scheduler, just use the following command Also, you can wrap your FastStream application the same way (allows to use lifespan events and AsyncAPI documentation): A little feature: instead of using a final message argument, you can set a message callback to collect information right before sending: Also, you can send a multiple message by one task call just using generator message callback with yield OpenTelemetry Support taskiq-faststream supports taskiq's OpenTelemetry middleware. To enable it, pass OpenTelemetryMiddleware when creating the broker wrapper: This will automatically add OpenTelemetry middleware to track task execution, providing insights into: - Task exec","default_branch":null,"files":null,"tree":[],"storefront":"/r/taskiq-python","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/taskiq-python/taskiq-faststream/request-supported","requests":0},"note":"indexed from public GitHub; nothing is for sale on this page. Clone it from GitHub. Paid listings live at /search."}