Azure queue and distributed lock providers for LiteFlow
Project description
Azure synchronization providers for LiteFlow
Provides support to use Azure storage as a shared work queue and distributed lock service for LiteFlow
Installing
Install the "liteflow.providers.azure" package
> pip install liteflow.providers.azure
Usage
Pass an instances of AzureQueueProvider and AzureLockProvider to configure_workflow_host
when configuring your workflow node host.
from azure.storage.common import CloudStorageAccount
from liteflow.core import *
from liteflow.providers.azure import AzureQueueProvider, AzureLockProvider
azure_storage_account = CloudStorageAccount(account_name='my account', account_key='my key')
azure_queue_service = AzureQueueProvider(azure_storage_account)
azure_lock_service = AzureLockProvider(azure_storage_account)
host = configure_workflow_host(queue_service=azure_queue_service,
lock_service=azure_lock_service)
host.start()
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Close
Hashes for liteflow.providers.azure-0.3.1.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | 59f6aee2f4ac6d0d90894445a8ee952f81e9446e85f0f73196bcd9e5a0798404 |
|
MD5 | 2c3f7963b4aeb3c8e79202124e50206e |
|
BLAKE2b-256 | 9cd5c75d2acb7353b9c6075c9bc6c7c9c9f22ccfc9c92942685047f267018f07 |
Close
Hashes for liteflow.providers.azure-0.3.1-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 715be7a29c41e3b1f1cee7bcbdad045eb99e5e979d661c981434fde6565f49cb |
|
MD5 | 34c7343a74aeebc9c901a00f6b35ff82 |
|
BLAKE2b-256 | 4c3a57faf6a1554c975562ea39da4e62099429fb2deddef4e41e388a1d8ae7ca |