Azure Functions 的 Dapr 服務調用觸發程式

[FunctionName("CreateNewOrder")]
public static void Run(
    [DaprServiceInvocationTrigger] JObject payload,
    [DaprState("%StateStoreName%", Key = "order")] out JToken order,
    ILogger log)
{
    log.LogInformation("C# function processed a CreateNewOrder request from the Dapr Runtime.");

    // payload must be of the format { "data": { "value": "some value" } }
    order = payload["data"];
}

app使用 物件來註冊 daprInvokeOutput：

const { app, trigger } = require('@azure/functions');

app.generic('InvokeOutputBinding', {
    trigger: trigger.generic({
        type: 'httpTrigger',
        authLevel: 'anonymous',
        methods: ['POST'],
        route: "invoke/{appId}/{methodName}",
        name: "req"
    }),
    return: daprInvokeOutput,
    handler: async (request, context) => {
        context.log("Node HTTP trigger function processed a request.");

        const payload = await request.text();
        context.log(JSON.stringify(payload));

        return { body: payload };
    }
});

以下範例展示了 function.json 檔案中的 Dapr 觸發器以及使用這些綁定的 JavaScript 程式碼。

以下是 的 daprServiceInvocationTrigger 檔案：

{
  "bindings": [
    {
      "type": "daprServiceInvocationTrigger",
      "name": "payload"
    }
  ]
}

如需 function.json 檔案屬性的詳細資訊，請參閱設定一節。

以下是 JavaScript 程式碼：

module.exports = async function (context) {
    context.log("Node function processed a RetrieveOrder request from the Dapr Runtime.");

    // print the fetched state value
    context.log(context.bindings.data);
};

下列範例示範使用 v2 Python 程式設計模型的 Dapr 服務調用觸發程式。 daprServiceInvocationTrigger若要在 Python 函式應用程式程式代碼中使用 ：

import logging
import json
import azure.functions as func

app = func.FunctionApp()

@app.function_name(name="RetrieveOrder")
@app.dapr_service_invocation_trigger(arg_name="payload", method_name="RetrieveOrder")
@app.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)

下列範例示範使用 v1 Python 程式設計模型的 Dapr 服務調用觸發程式。

以下是 的 daprServiceInvocationTrigger 檔案：

{
  "scriptFile": "__init__.py",
  "bindings": [
    {
      "type": "daprServiceInvocationTrigger",
      "name": "payload",
      "direction": "in"
    }
  ]
}

如需 function.json 檔案屬性的詳細資訊，請參閱設定一節。

以下是 Python 程式碼：

import logging
import json
import azure.functions as func

def main(payload, data: str) -> None:
    logging.info('Python function processed a RetrieveOrder request from the Dapr Runtime.')
    logging.info(data)

在 進行中模型中，使用來 DaprServiceInvocationTrigger 觸發 DAPR 服務調用綁定，該綁定支援以下特性。

在 隔離的背景工作模型中，使用 DaprServiceInvocationTrigger 來定義支援這些參數的 Dapr 服務調用觸發程式：

下表說明您在程式碼中設定的繫結設定屬性。

下表說明您在 function.json 檔案中設定的繫結設定屬性。

下表說明您在 Python 程式碼中設定的 @dapp.dapr_service_invocation_trigger 繫結組態屬性。

下表說明您在 function.json 檔案中設定的繫結設定屬性。

若要在 Python v2 中使用 daprServiceInvocationTrigger，請設定您的專案使其具備正確的相依性。

1. 建立並啟用虛擬環境。

2. 在 requirements.text 檔案中新增以下這一行：

   azure-functions==1.18.0b3
   

3. 在終端機中，安裝 Python 程式庫。

   pip install -r .\requirements.txt
   

4. 使用下列組態修改您的 local.setting.json 檔案：

   "PYTHON_ISOLATE_WORKER_DEPENDENCIES":1
   

除了設定服務調用元件之外，Python v1 模型不需要其他變更。