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.2.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | 89e9d8680bab259f9a8304841d7e0ec3a3ab2eeb489b927b148e5d3946c748a7 |
|
MD5 | 76a3450d0763295837a8b2d5ed1e4935 |
|
BLAKE2b-256 | bd9826e7bc45c2a654c36c56512d806547e783aee070764e2b335b8998dee78d |
Close
Hashes for liteflow.providers.azure-0.2-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | b023c33a1cd1cd2e4711c46a23fb1956a175a75aafa103bde7273541be6d428d |
|
MD5 | 7afabc94bdde899244fe7ebad9891fe8 |
|
BLAKE2b-256 | 57fe694f9fe19f1bba28daa5152774052252a8d5face5cc433ab75d662a639d2 |