<reponame>rustammendel/nifi-minifi-cpp
from ..core.Processor import Processor


class AzureBlobStorageProcessorBase(Processor):
    def __init__(self, name, additional_properties={}, schedule={"scheduling strategy": "TIMER_DRIVEN"}):
        super(AzureBlobStorageProcessorBase, self).__init__(
            name,
            properties={
                'Container Name': 'test-container',
                'Connection String': 'DefaultEndpointsProtocol=http;AccountName=devstoreaccount1;AccountKey=<KEY>;BlobEndpoint=http://azure-storage-server:10000/devstoreaccount1;QueueEndpoint=http://azure-storage-server:10001/devstoreaccount1;',
                'Blob': 'test-blob',
                **additional_properties
            },
            schedule=schedule,
            auto_terminate=['success', 'failure'])

from ..core.Processor import Processor


class AzureBlobStorageProcessorBase(Processor):
    def __init__(self, name, additional_properties={}, schedule={"scheduling strategy": "TIMER_DRIVEN"}):
        super(AzureBlobStorageProcessorBase, self).__init__(
            name,
            properties={
                'Container Name': 'test-container',
                'Connection String': 'DefaultEndpointsProtocol=http;AccountName=devstoreaccount1;AccountKey=<KEY>;BlobEndpoint=http://azure-storage-server:10000/devstoreaccount1;QueueEndpoint=http://azure-storage-server:10001/devstoreaccount1;',
                'Blob': 'test-blob',
                **additional_properties
            },
            schedule=schedule,
            auto_terminate=['success', 'failure'])