fix: add default credential for MI (#85)

* Adding default credential

* lint

* lint

* install compatible versions

---------

Co-authored-by: Victoria Hall <victoria.hall@microsoft.com>

Author: hallvictoria

azurefunctions-extensions-bindings-blob/azurefunctions/extensions/bindings/blob/blobClient.py

@@ -4,6 +4,7 @@
 import json
 from typing import Union
 
+from azure.identity import DefaultAzureCredential
 from azure.storage.blob import BlobServiceClient
 from azurefunctions.extensions.base import Datum, SdkType
 from .utils import get_connection_string, using_managed_identity
@@ -44,7 +45,9 @@ def get_sdk_type(self):
         """
         if self._data:
             blob_service_client = (
-                BlobServiceClient(account_url=self._connection)
+                BlobServiceClient(
+                    account_url=self._connection, credential=DefaultAzureCredential()
+                )
                 if self._using_managed_identity
                 else BlobServiceClient.from_connection_string(self._connection)
             )

azurefunctions-extensions-bindings-blob/azurefunctions/extensions/bindings/blob/containerClient.py

@@ -4,6 +4,7 @@
 import json
 from typing import Union
 
+from azure.identity import DefaultAzureCredential
 from azure.storage.blob import BlobServiceClient
 from azurefunctions.extensions.base import Datum, SdkType
 from .utils import get_connection_string, using_managed_identity
@@ -36,7 +37,9 @@ def __init__(self, *, data: Union[bytes, Datum]) -> None:
     def get_sdk_type(self):
         if self._data:
             blob_service_client = (
-                BlobServiceClient(account_url=self._connection)
+                BlobServiceClient(
+                    account_url=self._connection, credential=DefaultAzureCredential()
+                )
                 if self._using_managed_identity
                 else BlobServiceClient.from_connection_string(self._connection)
             )

azurefunctions-extensions-bindings-blob/azurefunctions/extensions/bindings/blob/storageStreamDownloader.py

@@ -4,6 +4,7 @@
 import json
 from typing import Union
 
+from azure.identity import DefaultAzureCredential
 from azure.storage.blob import BlobServiceClient
 from azurefunctions.extensions.base import Datum, SdkType
 from .utils import get_connection_string, using_managed_identity
@@ -36,7 +37,9 @@ def __init__(self, *, data: Union[bytes, Datum]) -> None:
     def get_sdk_type(self):
         if self._data:
             blob_service_client = (
-                BlobServiceClient(account_url=self._connection)
+                BlobServiceClient(
+                    account_url=self._connection, credential=DefaultAzureCredential()
+                )
                 if self._using_managed_identity
                 else BlobServiceClient.from_connection_string(self._connection)
             )

azurefunctions-extensions-bindings-blob/pyproject.toml

@@ -25,7 +25,8 @@ classifiers= [
     ]
 dependencies = [
     'azurefunctions-extensions-base',
-    'azure-storage-blob==12.24.0'
+    'azure-storage-blob~=12.24.0',
+    'azure-identity~=1.19.0'
     ]
 
 [project.optional-dependencies]