From 851359c1fc09f65661ae236660b5ebcb655d9e67 Mon Sep 17 00:00:00 2001 From: Sushil Kumar Date: Mon, 27 Apr 2020 16:44:55 -0700 Subject: [PATCH] NIFI-6913: PutAzureBlobStorage processor will create container if not exists Signed-off-by: Pierre Villard This closes #4237. --- .../nifi/processors/azure/storage/PutAzureBlobStorage.java | 1 + .../nifi/processors/azure/storage/utils/AzureStorageUtils.java | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/PutAzureBlobStorage.java b/nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/PutAzureBlobStorage.java index f42e4b3532..0a3bc253d7 100644 --- a/nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/PutAzureBlobStorage.java +++ b/nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/PutAzureBlobStorage.java @@ -75,6 +75,7 @@ public class PutAzureBlobStorage extends AbstractAzureBlobProcessor { try { CloudBlobClient blobClient = AzureStorageUtils.createCloudBlobClient(context, getLogger(), flowFile); CloudBlobContainer container = blobClient.getContainerReference(containerName); + container.createIfNotExists(); CloudBlob blob = container.getBlockBlobReference(blobPath); diff --git a/nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/utils/AzureStorageUtils.java b/nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/utils/AzureStorageUtils.java index 0e1dfd2180..bae72090fb 100644 --- a/nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/utils/AzureStorageUtils.java +++ b/nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/utils/AzureStorageUtils.java @@ -88,7 +88,7 @@ public final class AzureStorageUtils { public static final PropertyDescriptor CONTAINER = new PropertyDescriptor.Builder() .name("container-name") .displayName("Container Name") - .description("Name of the Azure storage container") + .description("Name of the Azure storage container. In case of PutAzureBlobStorage processor, container will be created if it does not exist.") .addValidator(StandardValidators.NON_EMPTY_VALIDATOR) .expressionLanguageSupported(ExpressionLanguageScope.FLOWFILE_ATTRIBUTES) .required(true)