{"repo":"taskiq-python/taskiq-redis","free":true,"listed":false,"github":"https://github.com/taskiq-python/taskiq-redis","clone":"git clone https://github.com/taskiq-python/taskiq-redis.git","description":"Broker and result backend for taskiq","language":"Python","stars":92,"topics":["asyncio","python","redis","taskiq","taskiq-broker","taskiq-result-backend"],"license":"MIT","category":"databases-storage","readme_excerpt":"TaskIQ-Redis Taskiq-redis is a plugin for taskiq that adds a new broker and result backend based on redis. Installation To use this project you must have installed core taskiq library: This project can be installed using pip: Usage Let's see the example with the redis broker and redis async result: Launch the workers: taskiq worker broker:broker Then run the main code: python3 broker.py Brokers This package contains 6 broker implementations. 3 broker types: PubSub broker ListQueue broker Stream broker Each of type is implemented for each redis architecture: Single node Cluster Sentinel Here's a small breakdown of how they differ from eachother. PubSub By default on old redis versions PUBSUB was the way of making redis into a queue. But using PUBSUB means that all messages delivered to all subscribed consumers. [!WARNING] This broker doesn't support acknowledgements. If during message processing Worker was suddenly killed the message is going to be lost. ListQueue This broker creates a list of messages at some key. Adding new tasks will be done by appending them from the left side using lpush , and taking them from the right side using brpop . [!WARNING] This broker doesn't support acknowledgements. If during message processing Worker was suddenly killed the message is going to be lost. Stream Stream brokers use redis stream type to store and fetch messages. [!TIP] This broker supports acknowledgements and therefore is fine to use in cases when data durability is required. Red","default_branch":null,"files":null,"tree":[],"storefront":"/r/taskiq-python","claimed":false,"request_supported":{"post":"https://gitbuyer.com/r/taskiq-python/taskiq-redis/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."}