move function app to individual blueprint

Signed-off-by: MD Ashique <noorani.ashique5@gmail.com>

Author: ASHIQUEMD

samples/python-azurefunction/README.md

@@ -1,6 +1,7 @@
 # Python Azure Function Sample
 
-This tutorial will demonstrate how to use Azure Functions Python programming model to integrate with multiple Dapr components.  Please first go through the [samples](https://github.com/dapr/samples) to get some contexts on various Dapr building blocks as well as go through Azure Functions [hello-world sample](https://docs.microsoft.com/en-us/azure/azure-functions/functions-create-first-function-vs-code?pivots=programming-language-python) to familiarize with function programming model.
+This tutorial will demonstrate how to use Azure Functions Python programming model to integrate with multiple Dapr components.  Please first go through the [samples](https://github.com/dapr/samples) to get some contexts on various Dapr building blocks as well as go through Azure Functions [hello-world sample](https://docs.microsoft.com/en-us/azure/azure-functions/functions-create-first-function-vs-code?pivots=programming-language-python) to familiarize with function programming model. [Please explore Functions Dapr extension with Python V2 programming model samples for simplified development](https://github.com/Azure/azure-functions-dapr-extension/tree/master/samples/python-v2-azurefunctions).
+
 We'll be running a Darp'd function app locally:
 1) Invoked by [Dapr Service Invocation](https://docs.dapr.io/developing-applications/building-blocks/service-invocation/service-invocation-overview/) and persist/retrieve state using [Dapr State Management](https://github.com/dapr/components-contrib/tree/master/state)
 2) Publish/consume message on a specific topic powered by [Dapr pub/sub](https://github.com/dapr/components-contrib/tree/master/pubsub) and `DaprPublish`/`DaprTopicTrigger`

samples/python-v2-azurefunctions/.funcignore

@@ -52,6 +52,14 @@ spec:
 ....
 ```
 
+# DaprBlueprint
+The Python v2 programming model introduces the concept of blueprints. A blueprint is a new class that's instantiated to register functions outside of the core function application. The functions registered in blueprint instances aren't indexed directly by the function runtime. To get these blueprint functions indexed, the function app needs to register the functions from blueprint instances.
+
+## Using blueprints provides the following benefits:
+
+- Lets you break up the function app into modular components, which enables you to define functions in multiple Python files and divide them into different components per file.
+- Provides extensible public function app interfaces to build and reuse your own APIs.
+
 # Step 2 - Run Function App with Dapr
 
 Build the function app:

samples/python-v2-azurefunctions/README.md

@@ -0,0 +1,11 @@
+import logging 
+import azure.functions as func 
+
+consumeMessageFromKafka = func.DaprBlueprint()
+
+# Dapr binding trigger
+@consumeMessageFromKafka.function_name(name="ConsumeMessageFromKafka")
+@consumeMessageFromKafka.dapr_binding_trigger(arg_name="triggerData", binding_name="%KafkaBindingName%")
+def main(triggerData: str) -> None:
+    logging.info('Python function processed a ConsumeMessageFromKafka request from the Dapr Runtime.')
+    logging.info('Trigger data: ' + triggerData)

samples/python-v2-azurefunctions/consume_message_from_kafka.py

@@ -0,0 +1,17 @@
+import logging 
+import azure.functions as func 
+
+createNewOrder = func.DaprBlueprint()
+
+# Dapr state output binding with http dapr_service_invocation_trigger
+@createNewOrder.function_name(name="CreateNewOrder")
+@createNewOrder.dapr_service_invocation_trigger(arg_name="payload", method_name="CreateNewOrder")
+@createNewOrder.dapr_state_output(arg_name="state", state_store="%StateStoreName%", key="order")
+def main(payload: str, state: func.Out[str] ) :
+    # request body must be passed this way '{\"value\": { \"key\": \"some value\" } }'
+    logging.info('Python function processed a CreateNewOrder request from the Dapr Runtime.')
+    logging.info(payload)
+    if payload is not None:
+        state.set(payload)
+    else:
+        logging.info('payload is none')

samples/python-v2-azurefunctions/create_new_order.py

@@ -1,125 +1,20 @@
-# import logging
-# import json
-# import azure.functions as func
-
-
-# def main(payload,
-#          order: func.Out[str]) -> None:
-#     logging.info(
-#         'Python function processed a CreateNewOrder request from the Dapr Runtime.')
-#     payload_json = json.loads(payload)
-#     logging.info(payload_json["data"])
-#     order.set(json.dumps({"value": payload_json["data"]}))
-
-
-import json
 import azure.functions as func
-import logging
-import json
-import azure.functions as func
-import logging
-from dapr_blueprint_app import app
-
-dapp = func.DaprFunctionApp()
-dapp.register_blueprint(app)
-
-# Dapr state output binding with http trigger
-@dapp.function_name(name="HttpTriggerFunc")
-@dapp.route(route="req", auth_level=dapp.auth_level.ANONYMOUS)
-@dapp.dapr_state_output(arg_name="state", state_store="statestore", key="newOrder")
-def main(req: func.HttpRequest, state: func.Out[str] ) -> str:
-    # request body must be passed this way '{\"value\": { \"key\": \"some value\" } }'
-    body = req.get_body()
-    logging.info(body.decode('utf-8'))
-    if body is not None:
-        state.set(body.decode('utf-8'))
-        logging.info(body.decode('utf-8'))
-    else:
-        logging.info('req body is none')
-    return 'ok'
 
-# Dapr state output binding with http dapr_service_invocation_trigger
-@dapp.function_name(name="CreateNewOrder")
-@dapp.dapr_service_invocation_trigger(arg_name="payload", method_name="CreateNewOrder")
-@dapp.dapr_state_output(arg_name="state", state_store="statestore", key="order")
-def main(payload: str, state: func.Out[str] ) :
-    # request body must be passed this way '{\"value\": { \"key\": \"some value\" } }'
-    logging.info('Python function processed a CreateNewOrder request from the Dapr Runtime.')
-    logging.info(payload)
-    if payload is not None:
-        state.set(payload)
-    else:
-        logging.info('payload is none')
+from create_new_order import createNewOrder
+from consume_message_from_kafka import consumeMessageFromKafka
+from invoke_output_binding import invokeOutputBinding
+from print_topic_message import printTopicMessage
+from retrieve_order import retrieveOrder
+from retrieve_secret import retrieveSecret
+from send_message_to_kafka import sendMessageToKafka
+from transfer_event_between_topics import transferEventBetweenTopics
 
-# Dapr state input binding with http dapr_service_invocation_trigger
-@dapp.function_name(name="RetrieveOrder")
-@dapp.dapr_service_invocation_trigger(arg_name="payload", method_name="RetrieveOrder")
-@dapp.dapr_state_input(arg_name="data", state_store="statestore", key="order")
-def main(payload, data: str) :
-    # Function should be invoked with this command: dapr invoke --app-id functionapp --method RetrieveOrder  --data '{}'
-    logging.info('Python function processed a RetrieveOrder request from the Dapr Runtime.')
-    logging.info(data)
-
-# Dapr secret input binding with http dapr_service_invocation_trigger
-@dapp.function_name(name="RetrieveSecret")
-@dapp.dapr_service_invocation_trigger(arg_name="payload", method_name="RetrieveSecret")
-@dapp.dapr_secret_input(arg_name="secret", secret_store_name="localsecretstore", key="my-secret", metadata="metadata.namespace=default")
-def main(payload, secret: str) :
-    # Function should be invoked with this command: dapr invoke --app-id functionapp --method RetrieveSecret  --data '{}'
-    logging.info('Python function processed a RetrieveSecret request from the Dapr Runtime.')
-    secret_dict = json.loads(secret)
-
-    for key in secret_dict:
-        logging.info("Stored secret: Key = " + key +
-                     ', Value = ' + secret_dict[key])
-        
-# Dapr binding output
-# Dapr state output binding with http dapr_service_invocation_trigger
-@dapp.function_name(name="SendMessageToKafka")
-@dapp.dapr_service_invocation_trigger(arg_name="payload", method_name="SendMessageToKafka")
-@dapp.dapr_binding_output(arg_name="messages", binding_name="%KafkaBindingName%", operation="create")
-def main(payload: str, messages: func.Out[bytes]) -> None:
-    logging.info('Python processed a SendMessageToKafka request from the Dapr Runtime.')
-    messages.set(json.dumps({"data": payload}).encode('utf-8'))
-
-# Dapr binding trigger
-@dapp.function_name(name="ConsumeMessageFromKafka")
-@dapp.dapr_binding_trigger(arg_name="triggerData", binding_name="%KafkaBindingName%")
-def main(triggerData: str) -> None:
-    logging.info('Python function processed a ConsumeMessageFromKafka request from the Dapr Runtime.')
-    logging.info('Trigger data: ' + triggerData)
-
-# Dapr topic trigger
-@dapp.function_name(name="PrintTopicMessage")
-@dapp.dapr_topic_trigger(arg_name="subEvent", pub_sub_name="%PubSubName%", topic="B", route="B")
-def main(subEvent) -> None:
-    logging.info('Python function processed a PrintTopicMessage request from the Dapr Runtime.')
-    subEvent_json = json.loads(subEvent)
-    logging.info("Topic B received a message: " + subEvent_json["data"])
-
-# Dapr publish output
-# Dapr topic trigger with dapr_publish_output
-@dapp.function_name(name="TransferEventBetweenTopics")
-@dapp.dapr_topic_trigger(arg_name="subEvent", pub_sub_name="%PubSubName%", topic="A", route="A")
-@dapp.dapr_publish_output(arg_name="pubEvent", pub_sub_name="%PubSubName%", topic="B")
-def main(subEvent, pubEvent: func.Out[bytes]) -> None:
-    logging.info('Python function processed a TransferEventBetweenTopics request from the Dapr Runtime.')
-    subEvent_json = json.loads(subEvent)
-    payload = "Transfer from Topic A: " + str(subEvent_json["data"])
-    pubEvent.set(json.dumps({"payload": payload}).encode('utf-8'))
-
-# Dapr invoke output binding with http trigger
-@dapp.function_name(name="InvokeOutputBinding")
-@dapp.route(route="invoke/{appId}/{methodName}", auth_level=dapp.auth_level.ANONYMOUS)
-@dapp.dapr_invoke_output(arg_name = "payload", app_id = "{appId}", method_name = "{methodName}", http_verb = "post")
-def main(req: func.HttpRequest, payload: func.Out[str] ) -> str:
-    # request body must be passed this way "{\"body\":{\"value\":{\"key\":\"some value\"}}}" to use the InvokeOutputBinding, all the data must be enclosed in body property.
-    logging.info('Python function processed a InvokeOutputBinding request from the Dapr Runtime.')
-
-    body = req.get_body()
-    logging.info(body)
-    if body is not None:
-        payload.set(body)
-    else:
-        logging.info('req body is none')
-    return 'ok'
+dapp = func.DaprFunctionApp()
+dapp.register_blueprint(createNewOrder)
+dapp.register_blueprint(consumeMessageFromKafka)
+dapp.register_blueprint(invokeOutputBinding)
+dapp.register_blueprint(printTopicMessage)
+dapp.register_blueprint(retrieveOrder)
+dapp.register_blueprint(retrieveSecret)
+dapp.register_blueprint(sendMessageToKafka)
+dapp.register_blueprint(transferEventBetweenTopics)

samples/python-v2-azurefunctions/dapr_blueprint_app.py

@@ -0,0 +1,20 @@
+import logging 
+import azure.functions as func 
+
+invokeOutputBinding = func.DaprBlueprint()
+
+# Dapr invoke output binding with http trigger
+@invokeOutputBinding.function_name(name="InvokeOutputBinding")
+@invokeOutputBinding.route(route="invoke/{appId}/{methodName}", auth_level=func.AuthLevel.ANONYMOUS)
+@invokeOutputBinding.dapr_invoke_output(arg_name = "payload", app_id = "{appId}", method_name = "{methodName}", http_verb = "post")
+def main(req: func.HttpRequest, payload: func.Out[str] ) -> str:
+    # request body must be passed this way "{\"body\":{\"value\":{\"key\":\"some value\"}}}" to use the InvokeOutputBinding, all the data must be enclosed in body property.
+    logging.info('Python function processed a InvokeOutputBinding request from the Dapr Runtime.')
+    
+    body = req.get_body()
+    logging.info(body)
+    if body is not None:
+        payload.set(body)
+    else:
+        logging.info('req body is none')
+    return 'ok'

samples/python-v2-azurefunctions/function_app.py

@@ -0,0 +1,13 @@
+import json
+import logging 
+import azure.functions as func 
+
+printTopicMessage = func.DaprBlueprint()
+
+# Dapr topic trigger
+@printTopicMessage.function_name(name="PrintTopicMessage")
+@printTopicMessage.dapr_topic_trigger(arg_name="subEvent", pub_sub_name="%PubSubName%", topic="B", route="B")
+def main(subEvent) -> None:
+    logging.info('Python function processed a PrintTopicMessage request from the Dapr Runtime.')
+    subEvent_json = json.loads(subEvent)
+    logging.info("Topic B received a message: " + subEvent_json["data"])

samples/python-v2-azurefunctions/invoke_output_binding.py

@@ -0,0 +1,13 @@
+import logging 
+import azure.functions as func 
+
+retrieveOrder = func.DaprBlueprint()
+
+# Dapr state input binding with http dapr_service_invocation_trigger
+@retrieveOrder.function_name(name="RetrieveOrder")
+@retrieveOrder.dapr_service_invocation_trigger(arg_name="payload", method_name="RetrieveOrder")
+@retrieveOrder.dapr_state_input(arg_name="data", state_store="%StateStoreName%", key="order")
+def main(payload, data: str) :
+    # Function should be invoked with this command: dapr invoke --app-id functionapp --method RetrieveOrder  --data '{}'
+    logging.info('Python function processed a RetrieveOrder request from the Dapr Runtime.')
+    logging.info(data)

samples/python-v2-azurefunctions/print_topic_message.py

@@ -0,0 +1,18 @@
+import json
+import logging 
+import azure.functions as func 
+
+retrieveSecret = func.DaprBlueprint()
+
+# Dapr secret input binding with http dapr_service_invocation_trigger
+@retrieveSecret.function_name(name="RetrieveSecret")
+@retrieveSecret.dapr_service_invocation_trigger(arg_name="payload", method_name="RetrieveSecret")
+@retrieveSecret.dapr_secret_input(arg_name="secret", secret_store_name="localsecretstore", key="my-secret", metadata="metadata.namespace=default")
+def main(payload, secret: str) :
+    # Function should be invoked with this command: dapr invoke --app-id functionapp --method RetrieveSecret  --data '{}'
+    logging.info('Python function processed a RetrieveSecret request from the Dapr Runtime.')
+    secret_dict = json.loads(secret)
+
+    for key in secret_dict:
+        logging.info("Stored secret: Key = " + key +
+                     ', Value = ' + secret_dict[key])

samples/python-v2-azurefunctions/retrieve_order.py

@@ -0,0 +1,14 @@
+import json
+import logging 
+import azure.functions as func 
+
+sendMessageToKafka = func.DaprBlueprint()
+
+# Dapr binding output
+# Dapr state output binding with http dapr_service_invocation_trigger
+@sendMessageToKafka.function_name(name="SendMessageToKafka")
+@sendMessageToKafka.dapr_service_invocation_trigger(arg_name="payload", method_name="SendMessageToKafka")
+@sendMessageToKafka.dapr_binding_output(arg_name="messages", binding_name="%KafkaBindingName%", operation="create")
+def main(payload: str, messages: func.Out[bytes]) -> None:
+    logging.info('Python processed a SendMessageToKafka request from the Dapr Runtime.')
+    messages.set(json.dumps({"data": payload}).encode('utf-8'))

samples/python-v2-azurefunctions/retrieve_secret.py

@@ -0,0 +1,16 @@
+import json
+import logging 
+import azure.functions as func 
+
+transferEventBetweenTopics = func.DaprBlueprint()
+
+# Dapr publish output
+# Dapr topic trigger with dapr_publish_output
+@transferEventBetweenTopics.function_name(name="TransferEventBetweenTopics")
+@transferEventBetweenTopics.dapr_topic_trigger(arg_name="subEvent", pub_sub_name="%PubSubName%", topic="A", route="A")
+@transferEventBetweenTopics.dapr_publish_output(arg_name="pubEvent", pub_sub_name="%PubSubName%", topic="B")
+def main(subEvent, pubEvent: func.Out[bytes]) -> None:
+    logging.info('Python function processed a TransferEventBetweenTopics request from the Dapr Runtime.')
+    subEvent_json = json.loads(subEvent)
+    payload = "Transfer from Topic A: " + str(subEvent_json["data"])
+    pubEvent.set(json.dumps({"payload": payload}).encode('utf-8'))