Support listing blobs recursively in azure-blob scaler

Closes #1789 Signed-off-by: Ahmed ElSayed <[email protected]>
kedacore · Aug 16, 2021 · 878dd4e · 878dd4e
1 parent b27de0c
commit 878dd4e
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 5 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -26,7 +26,7 @@
 
 ### Improvements
 
-- TODO ([#XXX](https://github.com/kedacore/keda/pull/XXX))
+- Support listing blobs recursively in azure-blob scaler ([#1789](https://github.com/kedacore/keda/issues/1789))
 
 ### Breaking Changes
 

diff --git a/pkg/scalers/azure_blob_scaler.go b/pkg/scalers/azure_blob_scaler.go
@@ -5,6 +5,7 @@ import (
 	"fmt"
 	"net/http"
 	"strconv"
+	"strings"
 
 	"github.com/kedacore/keda/v2/pkg/scalers/azure"
 
@@ -81,12 +82,13 @@ func parseAzureBlobMetadata(config *ScalerConfig) (*azureBlobMetadata, kedav1alp
 		return nil, "", fmt.Errorf("no blobContainerName given")
 	}
 
-	if val, ok := config.TriggerMetadata["blobDelimiter"]; ok && val != "" {
-		meta.blobDelimiter = val
-	}
+	meta.blobDelimiter = config.TriggerMetadata["blobDelimiter"]
 
 	if val, ok := config.TriggerMetadata["blobPrefix"]; ok && val != "" {
-		meta.blobPrefix = val + meta.blobDelimiter
+		meta.blobPrefix = val
+		if !strings.HasSuffix(meta.blobPrefix, defaultBlobDelimiter) {
+			meta.blobPrefix += defaultBlobPrefix
+		}
 	}
 
 	endpointSuffix, err := azure.ParseAzureStorageEndpointSuffix(config.TriggerMetadata, azure.BlobEndpoint)