Metadata-Version: 2.4
Name: taskiq-service-bus
Version: 0.2.0
Summary: Azure servicebus broker for taskiq
Keywords: taskiq,azure,service bus,servicebus
Author: Hamilton Kibbe
Author-email: Hamilton Kibbe <ham@hamiltonkib.be>
License-Expression: MIT
Classifier: Typing :: Typed
Classifier: Programming Language :: Python
Classifier: Programming Language :: Python :: 3
Classifier: Programming Language :: Python :: 3 :: Only
Classifier: Programming Language :: Python :: 3.10
Classifier: Programming Language :: Python :: 3.11
Classifier: Programming Language :: Python :: 3.12
Classifier: Programming Language :: Python :: 3.13
Classifier: Operating System :: OS Independent
Classifier: Intended Audience :: Developers
Classifier: Topic :: System :: Networking
Classifier: Development Status :: 3 - Alpha
Requires-Dist: azure-servicebus>=7.14.3
Requires-Dist: taskiq>=0.12.1,<1
Maintainer: Hamilton Kibbe
Maintainer-email: Hamilton Kibbe <ham@hamiltonkib.be>
Requires-Python: >=3.10, <4
Description-Content-Type: text/markdown

# Azure Service Bus broker for Taskiq


Example:

```python
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 string](https://learn.microsoft.com/en-us/azure/service-bus-messaging/service-bus-python-how-to-use-queues?tabs=connection-string#get-the-connection-string)
- `queue_name` - Name of the Service Bus queue to use
- `max_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 use `uuid4`.