Azure Service Bus broker for Taskiq
Example:
from taskiq_service_bus import ServiceBusBroker
SERVICE_BUS_CONNECTION_STRING = "your_connection_string_here"
broker = ServiceBusBroker(SERVICE_BUS_CONNECTION_STRING, "my-queue")
@broker.task
def example_task():
print("Task executed successfully")
Broker Parameters
connection_string- Service Bus Namespace connection string. Instructions on how to find it can be found here: Get the connection stringqueue_name- Name of the Service Bus queue to usemax_lock_renewal_duration- Maximum message lock renewal duration in seconds. Optional, defaults to 300.result_backend- Result backend to use. Optional.task_id_generator- custom task ID generator function. Optional, if not provided, taskiq will useuuid4.
1 maintainer
Release files for taskiq-service-bus 0.3.0
For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.
Source distribution (sdist)
| File | Size | Uploaded | |
|---|---|---|---|
| taskiq_service_bus-0.3.0.tar.gz | 3.1 kB | Details |
Built distribution (wheel)
| File | Interpreter | ABI | Platform | Reset |
|---|---|---|---|---|
| taskiq_service_bus-0.3.0-py3-none-any.whl | Python 3 | none | any | Details |
Total release size: 7.1 kB
Release files / taskiq_service_bus-0.3.0.tar.gz
| Download URL | taskiq_service_bus-0.3.0.tar.gz |
|---|---|
| Size | 3.1 kB |
| Tags | Source |
|
SHA-256 checksum How to use checksums |
18a3b0db54549702ae429da82adad4b0d18f7f69e2850302b753a2ad998f75be
|
|
BLAKE2b-256 checksum How to use checksums |
48e65082f23370333b8fe2108eb123cb55af5eec4129eb91d9317d0ab12809a8
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
uv/0.11.14 {"installer":{"name":"uv","version":"0.11.14","subcommand":["publish"]},"python":null,"implementation":{"name":null,"version":null},"distro":{"name":"macOS","version":null,"id":null,"libc":null},"system":{"name":null,"release":null},"cpu":null,"openssl_version":null,"setuptools_version":null,"rustc_version":null,"ci":null}
|
Release files / taskiq_service_bus-0.3.0-py3-none-any.whl
| Download URL | taskiq_service_bus-0.3.0-py3-none-any.whl |
|---|---|
| Size | 3.9 kB |
| Tags | Python 3 |
|
SHA-256 checksum How to use checksums |
b64a4232d3a75c9c9cee8b54cd2a35a054184cea08e27602e1db60e5370ca024
|
|
BLAKE2b-256 checksum How to use checksums |
d8af77cacdd93a8b857b5ff76ca7632bef42f0dab17ae2c57a4a97cb1c107c35
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
uv/0.11.14 {"installer":{"name":"uv","version":"0.11.14","subcommand":["publish"]},"python":null,"implementation":{"name":null,"version":null},"distro":{"name":"macOS","version":null,"id":null,"libc":null},"system":{"name":null,"release":null},"cpu":null,"openssl_version":null,"setuptools_version":null,"rustc_version":null,"ci":null}
|
