feat: support CosmosDB SDK-type bindings (#109)

* Init

* Fix

* Add code qual

* Add docs

* Fix

* Chng docs

* Chng test

* Rename

* Fix

* Fix

* Fix

* Fix

* Fix

* Fix

* test

* TODO

---------

Co-authored-by: Evan Roman <[email protected]>
Co-authored-by: Gavin Aguiar <[email protected]>

Author: 3 people

azurefunctions-extensions-bindings-blob/README.md

@@ -56,7 +56,7 @@ import logging
 import azure.functions as func
 import azurefunctions.extensions.bindings.blob as blob
 
-app = func.FunctionApp(http_auth_level=func.AuthLevel.ANONYMOUS)
+app = func.FunctionApp(http_auth_level=func.AuthLevel.FUNCTION)
 
 @app.blob_trigger(arg_name="client",
                   path="PATH/TO/BLOB",

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

@@ -56,4 +56,4 @@ def get_sdk_type(self):
                 blob=self._blobName,
             )
         else:
-            return None
+            raise ValueError(f"Unable to create {self.__class__.__name__} SDK type.")

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

@@ -46,4 +46,4 @@ def get_sdk_type(self):
                 container=self._containerName
             )
         else:
-            return None
+            raise ValueError(f"Unable to create {self.__class__.__name__} SDK type.")

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

@@ -48,4 +48,4 @@ def get_sdk_type(self):
                 blob=self._blobName,
             ).download_blob()
         else:
-            return None
+            raise ValueError(f"Unable to create {self.__class__.__name__} SDK type.")

azurefunctions-extensions-bindings-blob/samples/blob_samples_blobclient/function_app.py

@@ -9,7 +9,7 @@
 import azure.functions as func
 import azurefunctions.extensions.bindings.blob as blob
 
-app = func.FunctionApp(http_auth_level=func.AuthLevel.ANONYMOUS)
+app = func.FunctionApp(http_auth_level=func.AuthLevel.FUNCTION)
 
 """
 FOLDER: blob_samples_blobclient

azurefunctions-extensions-bindings-blob/samples/blob_samples_containerclient/function_app.py

@@ -9,7 +9,7 @@
 import azure.functions as func
 import azurefunctions.extensions.bindings.blob as blob
 
-app = func.FunctionApp(http_auth_level=func.AuthLevel.ANONYMOUS)
+app = func.FunctionApp(http_auth_level=func.AuthLevel.FUNCTION)
 
 """
 FOLDER: blob_samples_containerclient

azurefunctions-extensions-bindings-blob/samples/blob_samples_storagestreamdownloader/function_app.py

@@ -9,7 +9,7 @@
 import azure.functions as func
 import azurefunctions.extensions.bindings.blob as blob
 
-app = func.FunctionApp(http_auth_level=func.AuthLevel.ANONYMOUS)
+app = func.FunctionApp(http_auth_level=func.AuthLevel.FUNCTION)
 
 """
 FOLDER: blob_samples_storagestreamdownloader

azurefunctions-extensions-bindings-blob/tests/test_blobclient.py

@@ -94,10 +94,10 @@ def test_input_incorrect_type(self):
 
     def test_input_empty(self):
         datum: Datum = Datum(value={}, type="model_binding_data")
-        result: BlobClient = BlobClientConverter.decode(
-            data=datum, trigger_metadata=None, pytype=BlobClient
-        )
-        self.assertIsNone(result)
+        with self.assertRaises(ValueError):
+            BlobClientConverter.decode(
+                data=datum, trigger_metadata=None, pytype=BlobClient
+            )
 
     def test_input_populated(self):
         content = {

azurefunctions-extensions-bindings-blob/tests/test_containerclient.py

@@ -94,10 +94,10 @@ def test_input_incorrect_type(self):
 
     def test_input_empty(self):
         datum: Datum = Datum(value={}, type="model_binding_data")
-        result: ContainerClient = BlobClientConverter.decode(
-            data=datum, trigger_metadata=None, pytype=ContainerClient
-        )
-        self.assertIsNone(result)
+        with self.assertRaises(ValueError):
+            BlobClientConverter.decode(
+                data=datum, trigger_metadata=None, pytype=ContainerClient
+            )
 
     def test_input_populated(self):
         content = {

azurefunctions-extensions-bindings-blob/tests/test_ssd.py

@@ -97,10 +97,10 @@ def test_input_incorrect_type(self):
 
     def test_input_empty(self):
         datum: Datum = Datum(value={}, type="model_binding_data")
-        result: StorageStreamDownloader = BlobClientConverter.decode(
-            data=datum, trigger_metadata=None, pytype=StorageStreamDownloader
-        )
-        self.assertIsNone(result)
+        with self.assertRaises(ValueError):
+            BlobClientConverter.decode(
+                data=datum, trigger_metadata=None, pytype=StorageStreamDownloader
+            )
 
     def test_input_populated(self):
         content = {