semvec/pypi-packages huggingface dataset:
taskiq-service-bus 0.1.0
Azure servicebus broker for taskiq
Requires Python: <4,>=3.10
Keywords: taskiq, azure, service bus, servicebus

# 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`.