Merge pull request #23 from ggailey777/vameru/pystein-improvements

Updating PyStein Examples

Author: ggailey777

articles/azure-functions/functions-bindings-cosmosdb-v2-input.md

@@ -1531,20 +1531,24 @@ The following example shows an Azure Cosmos DB input binding. The function reads
 # [v2](#tab/python-v2)
 
 ```python
+import logging
+import azure.functions as func
+
+app = func.FunctionApp()
+
 @app.queue_trigger(arg_name="msg", 
-   queue_name="outqueue", 
-   connection="AzureWebJobsStorage")
-@app.cosmos_db_input(
-    arg_name="documents", 
-    database_name="MyDatabase",
-    collection_name="MyCollection",
-    id="{msg.payload_property}",
-    partition_key="{msg.payload_property}",
-    connection_string_setting="MyAccount_COSMOSDB")
+                   queue_name="outqueue", 
+                   connection="AzureWebJobsStorage")
+@app.cosmos_db_input(arg_name="documents", 
+                     database_name="MyDatabase",
+                     collection_name="MyCollection",
+                     id="{msg.payload_property}",
+                     partition_key="{msg.payload_property}",
+                     connection_string_setting="MyAccount_COSMOSDB")
 @app.cosmos_db_output(arg_name="outputDocument", 
-    database_name="MyDatabase",", 
-    collection_name="MyCollection",
-    connection_string_setting="MyAccount_COSMOSDB")
+                      database_name="MyDatabase",
+                      collection_name="MyCollection",
+                      connection_string_setting="MyAccount_COSMOSDB")
 def test_function(msg: func.QueueMessage,
                   inputDocument: func.DocumentList, 
                   outputDocument: func.Out[func.Document]):

articles/azure-functions/functions-bindings-cosmosdb-v2-output.md

@@ -596,12 +596,15 @@ The following example demonstrates how to write a document to an Azure Cosmos DB
 ```python
 import logging
 import azure.functions as func
+
+app = func.FunctionApp()
+
 @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="CONNECTION_SETTING")
+@app.cosmos_db_output(arg_name="documents", 
+                      database_name="DB_NAME",
+                      collection_name="COLLECTION_NAME",
+                      create_if_not_exists=True,
+                      connection_string_setting="CONNECTION_SETTING")
 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))

articles/azure-functions/functions-bindings-cosmosdb-v2-trigger.md

@@ -294,9 +294,14 @@ The following example shows an Azure Cosmos DB trigger binding. The example depe
 ```python
 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=""AzureWebJobsStorage"",
+
+@app.function_name(name="CosmosDBTrigger")
+@app.cosmos_db_trigger(arg_name="documents", 
+                       database_name="DB_NAME", 
+                       collection_name="COLLECTION_NAME", 
+                       connection_string_setting="CONNECTION_SETTING",
  lease_collection_name="leases", create_lease_collection_if_not_exists="true")
 def test_function(documents: func.DocumentList) -> str:
     if documents:

articles/azure-functions/functions-bindings-event-hubs-output.md

@@ -195,12 +195,14 @@ The following example shows an event hub trigger binding and a Python function t
 ```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="CONNECTION_SETTING")
+                      event_hub_name="<EVENT_HUB_NAME>",
+                      connection="<CONNECTION_SETTING>")
 def eventhub_output(req: func.HttpRequest, event: func.Out[str]):
     body = req.get_body()
     if body is not None:

articles/azure-functions/functions-bindings-http-webhook-trigger.md

@@ -467,25 +467,16 @@ The following example shows a trigger binding and a Python function that uses th
 ```python
 import azure.functions as func
 import logging
-app = func.FunctionApp(auth_level=func.AuthLevel.ANONYMOUS)
+
+app = func.FunctionApp()
+
 @app.function_name(name="HttpTrigger1")
-@app.route(route="hello")
+@app.route(route="hello", auth_level=func.AuthLevel.ANONYMOUS)
 def test_function(req: func.HttpRequest) -> func.HttpResponse:
-     logging.info('Python HTTP trigger function processed a request.')
-     name = req.params.get('name')
-     if not name:
-        try:
-            req_body = req.get_json()
-        except ValueError:
-            pass
-        else:
-            name = req_body.get('name')
-     if name:
-        return func.HttpResponse(f"Hello, {name}. This HTTP triggered function executed successfully.")
-     else:
-        return func.HttpResponse(
-             "This HTTP triggered function executed successfully. Pass a name in the query string or in the request body for a personalized response.",
-             status_code=200
+    logging.info('Python HTTP trigger function processed a request.')
+    return func.HttpResponse(
+        "This HTTP triggered function executed successfully.",
+        status_code=200
         )
 ```
 

articles/azure-functions/functions-bindings-service-bus-output.md

@@ -240,12 +240,13 @@ The following example demonstrates how to write out to a Service Bus queue in Py
 ```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="CONNECTION_SETTING",
-    topic_name="mytopic")
+@app.service_bus_topic_output(arg_name="message",
+                              connection="<CONNECTION_SETTING>",
+                              topic_name="<TOPIC_NAME>")
 def main(req: func.HttpRequest, message: func.Out[str]) -> func.HttpResponse:
     input_msg = req.params.get('message')
     message.set(input_msg)

articles/azure-functions/functions-bindings-service-bus-trigger.md

@@ -213,9 +213,13 @@ The following example demonstrates how to read a Service Bus queue message via a
 ```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="CONNECTION_SETTING")
+@app.service_bus_queue_trigger(arg_name="msg", 
+                               queue_name="<QUEUE_NAME>", 
+                               connection="<CONNECTION_SETTING">)
 def test_function(msg: func.ServiceBusMessage):
     logging.info('Python ServiceBus queue trigger processed message: %s',
                  msg.get_body().decode('utf-8'))

articles/azure-functions/functions-bindings-storage-blob-input.md

@@ -253,15 +253,17 @@ The code creates a copy of a blob.
 ```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")
+                connection="<BLOB_CONNECTION_SETTING>")
 @app.blob_output(arg_name="outputblob",
                 path="newblob/test.txt",
-                connection="AzureWebJobsStorage")
+                connection="<BLOB_CONNECTION_SETTING>")
 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)

articles/azure-functions/functions-bindings-storage-blob-output.md

@@ -318,15 +318,17 @@ The code creates a copy of a blob.
 ```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")
+                connection="<BLOB_CONNECTION_SETTING>")
 @app.blob_output(arg_name="outputblob",
                 path="newblob/test.txt",
-                connection="AzureWebJobsStorage")
+                connection="<BLOB_CONNECTION_SETTING>")
 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)

articles/azure-functions/functions-bindings-storage-blob-trigger.md

@@ -217,10 +217,13 @@ The following example shows a blob trigger binding. The example depends on wheth
 ```python
 import logging
 import azure.functions as func
+
 app = func.FunctionApp()
+
 @app.function_name(name="BlobTrigger1")
-@app.blob_trigger(arg_name="myblob", path="samples-workitems/{name}",
-                  connection="AzureWebJobsStorage")
+@app.blob_trigger(arg_name="myblob", 
+                  path="PATH/TO/BLOB",
+                  connection="CONNECTION_SETTING")
 def test_function(myblob: func.InputStream):
    logging.info(f"Python blob trigger function processed blob \n"
                 f"Name: {myblob.name}\n"