用于liteflow的azure队列和分布式锁提供程序
liteflow.providers.azure的Python项目详细描述
用于liteflow的azure同步提供程序
支持将azure存储用作liteflow的共享工作队列和分布式锁服务
安装
安装“liteflow.providers.azure”包
> pip install liteflow.providers.azure
用法
配置工作流节点主机时,将azurequeueprovider和azurelockprovider的实例传递给configure_workflow_host
。
fromazure.storage.commonimportCloudStorageAccountfromliteflow.coreimport*fromliteflow.providers.azureimportAzureQueueProvider,AzureLockProviderazure_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()