Gatilho de invocação de serviço dapr para o Azure Functions

[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"];
}

Use o app objeto para registrar o 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 };
    }
});

Os exemplos a seguir mostram disparos do Dapr em um arquivo function.json e código JavaScript que utiliza essas vinculações.

Aqui está o arquivo function.json para o daprServiceInvocationTrigger:

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

Para obter mais informações sobre as propriedades do arquivo function.json, consulte a seção Configuração.

Aqui está o código 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);
};

O exemplo a seguir mostra um gatilho invocação de serviço dapr, que usa o modelo de programação python v2. Para usar o código do daprServiceInvocationTrigger aplicativo de funções do 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)

O exemplo a seguir mostra um gatilho invocação de serviço dapr, que usa o modelo de programação python v1.

Aqui está o arquivo function.json para o daprServiceInvocationTrigger:

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

Para obter mais informações sobre as propriedades do arquivo function.json, consulte a seção Configuração.

Aqui está o código 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)

No modelo em processo, use o DaprServiceInvocationTrigger para acionar uma ligação de invocação de serviço Dapr, que suporta as seguintes propriedades.

No modelo de trabalho isolado, use para DaprServiceInvocationTrigger definir um gatilho de invocação de serviço dapr, que dá suporte a esses parâmetros:

A tabela a seguir explica as propriedades de configuração de associação que você definiu no código.

A tabela a seguir explica as propriedades de configuração de associação que você define no arquivo function.json.

A tabela a seguir explica as propriedades de configuração de associação para @dapp.dapr_service_invocation_trigger definidas no código do Python.

A tabela a seguir explica as propriedades de configuração de associação que você define no arquivo function.json.

Para usar a opção daprServiceInvocationTrigger no Python v2, configure seu projeto com as dependências corretas.

1. Criar e ativar um ambiente virtual.

2. No arquivo requirements.text, adicione a seguinte linha:

   azure-functions==1.18.0b3
   

3. No terminal, instale a biblioteca do Python.

   pip install -r .\requirements.txt
   

4. Modifique seu arquivo local.setting.json com a seguinte configuração:

   "PYTHON_ISOLATE_WORKER_DEPENDENCIES":1
   

O modelo python v1 não requer alterações adicionais, além de configurar o componente de invocação de serviço.