Merge pull request #223848 from shreyabatra4/pystein-samples

added more samples

Author: v-regandowner

articles/azure-functions/functions-bindings-triggers-python.md

@@ -26,7 +26,7 @@ To create your first function in the new v2 model, see one of these quickstart a
 + [Get started with Visual Studio](./create-first-function-vs-code-python.md)
 + [Get started command prompt](./create-first-function-cli-python.md)
 
-## Blob trigger
+## Azure Blob storage trigger
 
 The following code snippet defines a function triggered from Azure Blob Storage:
 
@@ -36,13 +36,49 @@ import azure.functions as func
 app = func.FunctionApp()
 @app.function_name(name="BlobTrigger1")
 @app.blob_trigger(arg_name="myblob", path="samples-workitems/{name}",
-                  connection="<STORAGE_CONNECTION_SETTING>")
+                  connection="AzureWebJobsStorage")
 def test_function(myblob: func.InputStream):
    logging.info(f"Python blob trigger function processed blob \n"
                 f"Name: {myblob.name}\n"
                 f"Blob Size: {myblob.length} bytes")
 ```
 
+## Azure Blob storage input binding
+
+```python
+import logging
+import azure.functions as func
+app = func.FunctionApp()
+@app.function_name(name="BlobInput1")
+@app.route(route="file")
+@app.blob_input(arg_name="inputblob",
+                path="sample-workitems/{name}",
+                connection="AzureWebJobsStorage")
+def test(req: func.HttpRequest, inputblob: bytes) -> func.HttpResponse:
+    logging.info(f'Python Queue trigger function processed {len(inputblob)} bytes')
+    return inputblob
+```
+
+## Azure Blob storage output binding
+
+```python
+import logging
+import azure.functions as func
+app = func.FunctionApp()
+@app.function_name(name="BlobOutput1")
+@app.route(route="file")
+@app.blob_input(arg_name="inputblob",
+                path="sample-workitems/test.txt",
+                connection="AzureWebJobsStorage")
+@app.blob_output(arg_name="outputblob",
+                path="newblob/test.txt",
+                connection="AzureWebJobsStorage")
+def main(req: func.HttpRequest, inputblob: str, outputblob: func.Out[str]):
+    logging.info(f'Python Queue trigger function processed {len(inputblob)} bytes')
+    outputblob.set(inputblob)
+    return "ok"
+```
+
 ## Azure Cosmos DB trigger
 
 The following code snippet defines a function triggered from an Azure Cosmos DB (SQL API):
@@ -52,13 +88,45 @@ import logging
 import azure.functions as func
 app = func.FunctionApp()
 @app.function_name(name="CosmosDBTrigger1")
-@app.cosmos_db_trigger(arg_name="documents", database_name="<DB_NAME>", collection_name="<COLLECTION_NAME>", connection_string_setting="<COSMOS_CONNECTION_SETTING>",
+@app.cosmos_db_trigger(arg_name="documents", database_name="<DB_NAME>", collection_name="<COLLECTION_NAME>", connection_string_setting=""AzureWebJobsStorage"",
  lease_collection_name="leases", create_lease_collection_if_not_exists="true")
 def test_function(documents: func.DocumentList) -> str:
     if documents:
         logging.info('Document id: %s', documents[0]['id'])
 ```
 
+## Azure Cosmos DB input binding
+
+```python
+import logging
+import azure.functions as func
+app = func.FunctionApp()
+@app.route()
+@app.cosmos_db_input(
+    arg_name="documents", database_name="<DB_NAME>",
+    collection_name="<COLLECTION_NAME>",
+    connection_string_setting="AzureWebJobsStorage")
+def cosmosdb_input(req: func.HttpRequest, documents: func.DocumentList) -> str:
+    return func.HttpResponse(documents[0].to_json())
+```
+
+## Azure Cosmos DB output binding
+
+```python
+import logging
+import azure.functions as func
+@app.route()
+@app.cosmos_db_output(
+    arg_name="documents", database_name="<DB_NAME>",
+    collection_name="<COLLECTION_NAME>",
+    create_if_not_exists=True,
+    connection_string_setting="AzureWebJobsStorage")
+def main(req: func.HttpRequest, documents: func.Out[func.Document]) -> func.HttpResponse:
+    request_body = req.get_body()
+    documents.set(func.Document.from_json(request_body))
+    return 'OK'
+```
+
 ## Azure EventHub trigger
 
 The following code snippet defines a function triggered from an event hub instance:
@@ -69,12 +137,32 @@ import azure.functions as func
 app = func.FunctionApp()
 @app.function_name(name="EventHubTrigger1")
 @app.event_hub_message_trigger(arg_name="myhub", event_hub_name="samples-workitems",
-                               connection="<EVENT_HUB_CONNECTION_SETTING>") 
+                               connection=""AzureWebJobsStorage"") 
 def test_function(myhub: func.EventHubEvent):
     logging.info('Python EventHub trigger processed an event: %s',
                 myhub.get_body().decode('utf-8'))
 ```
 
+## Azure EventHub output binding
+
+```python
+import logging
+import azure.functions as func
+app = func.FunctionApp()
+@app.function_name(name="eventhub_output")
+@app.route(route="eventhub_output")
+@app.event_hub_output(arg_name="event",
+                      event_hub_name="samples-workitems",
+                      connection="AzureWebJobsStorage")
+def eventhub_output(req: func.HttpRequest, event: func.Out[str]):
+    body = req.get_body()
+    if body is not None:
+        event.set(body.decode('utf-8'))
+    else:    
+        logging.info('req body is none')
+    return 'ok'
+```
+
 ## HTTP trigger
 
 The following code snippet defines an HTTP triggered function:
@@ -104,28 +192,45 @@ def test_function(req: func.HttpRequest) -> func.HttpResponse:
         )
 ```
 
-## Azure Queue Storage trigger
+## Azure Queue storage trigger
 
 ```python
 import logging
 import azure.functions as func
 app = func.FunctionApp()
 @app.function_name(name="QueueTrigger1")
 @app.queue_trigger(arg_name="msg", queue_name="python-queue-items",
-                   connection="")  
+                   connection=""AzureWebJobsStorage"")  
 def test_function(msg: func.QueueMessage):
     logging.info('Python EventHub trigger processed an event: %s',
                  msg.get_body().decode('utf-8'))
 ```
 
+## Azure Queue storage output binding
+
+```python
+import logging
+import azure.functions as func
+app = func.FunctionApp()
+@app.function_name(name="QueueOutput1")
+@app.route(route="message")
+@app.queue_output(arg_name="msg", queue_name="python-queue-items", connection="AzureWebJobsStorage")
+def main(req: func.HttpRequest, msg: func.Out[str]) -> func.HttpResponse:
+    input_msg = req.params.get('name')
+    msg.set(input_msg)
+    logging.info(input_msg)
+    logging.info('name: {name}')
+    return 'OK'
+```
+
 ## Azure Service Bus queue trigger
 
 ```python
 import logging
 import azure.functions as func
 app = func.FunctionApp()
 @app.function_name(name="ServiceBusQueueTrigger1")
-@app.service_bus_queue_trigger(arg_name="msg", queue_name="myinputqueue", connection="")
+@app.service_bus_queue_trigger(arg_name="msg", queue_name="myinputqueue", connection="AzureWebJobsStorage")
 def test_function(msg: func.ServiceBusMessage):
     logging.info('Python ServiceBus queue trigger processed message: %s',
                  msg.get_body().decode('utf-8'))
@@ -138,13 +243,30 @@ import logging
 import azure.functions as func
 app = func.FunctionApp()
 @app.function_name(name="ServiceBusTopicTrigger1")
-@app.service_bus_topic_trigger(arg_name="message", topic_name="mytopic", connection="", subscription_name="testsub")
+@app.service_bus_topic_trigger(arg_name="message", topic_name="mytopic", connection="AzureWebJobsStorage", subscription_name="testsub")
 def test_function(message: func.ServiceBusMessage):
     message_body = message.get_body().decode("utf-8")
     logging.info("Python ServiceBus topic trigger processed message.")
     logging.info("Message Body: " + message_body)
 ```
 
+## Azure Service Bus Topic output binding
+
+```python
+import logging
+import azure.functions as func
+app = func.FunctionApp()
+@app.route(route="put_message")
+@app.service_bus_topic_output(
+    arg_name="message",
+    connection="AzureWebJobsStorage",
+    topic_name="mytopic")
+def main(req: func.HttpRequest, message: func.Out[str]) -> func.HttpResponse:
+    input_msg = req.params.get('message')
+    message.set(input_msg)
+    return 'OK'
+```
+
 ## Timer trigger
 
 ```python

articles/azure-functions/functions-reference-python.md

@@ -412,7 +412,7 @@ At this time, only specific triggers and bindings are supported by the Python v2
 | [Azure Service Bus topic](functions-bindings-triggers-python.md#azure-service-bus-topic-trigger) | x |   | x |
 | [Azure Service Bus queue](functions-bindings-triggers-python.md#azure-service-bus-queue-trigger) | x |   | x |
 | [Azure Cosmos DB](functions-bindings-triggers-python.md#azure-eventhub-trigger) | x | x | x |
-| [Azure Blob Storage](functions-bindings-triggers-python.md#blob-trigger) | x | x | x |
+| [Azure Blob Storage](functions-bindings-triggers-python.md#azure-blob-storage-trigger) | x | x | x |
 | [Azure Hub](functions-bindings-triggers-python.md#azure-eventhub-trigger) | x |   | x |
 
 For more examples, see [Python V2 model Azure Functions triggers and bindings (preview)](functions-bindings-triggers-python.md).