Enlaces para Durable Functions (Azure Functions)

Modelo de programación de Python v2

Durable Functions se admite en el nuevo modelo de programación de Python v2. Para usar el modelo v2, debe instalar el SDK de Durable Functions, que es el paquete azure-functions-durablepyPI, la versión 1.2.2 o una versión posterior. También debe comprobar host.json para asegurarse de que la aplicación hace referencia a Extension Bundles versión 4.x para usar el modelo v2 con Durable Functions.

Puede proporcionar comentarios y sugerencias en el repositorio del SDK de Durable Functions para Python.

Al crear funciones en .NET, el desencadenador de orquestación se configura mediante el atributo OrchestrationTriggerAttribute .NET.

Para Java, la @DurableOrchestrationTrigger anotación se usa para configurar el desencadenador de orquestación.

Al escribir funciones de orquestador, el desencadenador de orquestación se define mediante el siguiente objeto JSON en la bindings matriz del archivo function.json :

{
    "name": "<Name of input parameter in function signature>",
    "orchestration": "<Optional - name of the orchestration>",
    "type": "orchestrationTrigger",
    "direction": "in"
}

• orchestration es el nombre de la orquestación que los clientes deben usar cuando quieren iniciar nuevas instancias de esta función de orquestador. Esta propiedad es opcional. Si no se especifica, se usa el nombre de la función.

Azure Functions admite dos modelos de programación para Python. La forma en que se define un desencadenador de orquestación depende del modelo de programación elegido.

{
    "name": "<Name of input parameter in function signature>",
    "orchestration": "<Optional - name of the orchestration>",
    "type": "orchestrationTrigger",
    "direction": "in"
}

El atributo específico que se usa para definir el desencadenador depende de si ejecuta las funciones de C# en proceso o en un proceso de trabajo aislado.

[FunctionName("HelloWorld")]
public static string Run([OrchestrationTrigger] IDurableOrchestrationContext context)
{
    string name = context.GetInput<string>();
    return $"Hello {name}!";
}

[Function("HelloWorld")]
public static string Run([OrchestrationTrigger] TaskOrchestrationContext context, string name)
{
    return $"Hello {name}!";
}

const df = require("durable-functions");

module.exports = df.orchestrator(function*(context) {
    const name = context.df.getInput();
    return `Hello ${name}!`;
});

param($Context)

$InputData = $Context.Input
$InputData

@FunctionName("HelloWorldOrchestration")
public String helloWorldOrchestration(
        @DurableOrchestrationTrigger(name = "ctx") TaskOrchestrationContext ctx) {
    return String.format("Hello %s!", ctx.getInput(String.class));
}

La mayoría de las funciones del orquestador llaman a funciones de actividad, por lo que aquí tenemos un ejemplo de "Hola mundo" que muestra cómo llamar a una función de actividad:

const df = require("durable-functions");

module.exports = df.orchestrator(function*(context) {
    const name = context.df.getInput();
    const result = yield context.df.callActivity("SayHello", name);
    return result;
});

@FunctionName("HelloWorld")
public String helloWorldOrchestration(
        @DurableOrchestrationTrigger(name = "ctx") TaskOrchestrationContext ctx) {
    String input = ctx.getInput(String.class);
    String result = ctx.callActivity("SayHello", input, String.class).await();
    return result;
}

El desencadenador de actividad se configura mediante el atributo ActivityTriggerAttribute .NET.

El desencadenador de actividad se configura mediante la anotación @DurableActivityTrigger.

El desencadenador de actividad se define mediante el siguiente objeto JSON en la bindings matriz de function.json:

{
    "name": "<Name of input parameter in function signature>",
    "activity": "<Optional - name of the activity>",
    "type": "activityTrigger",
    "direction": "in"
}

• activity es el nombre de la actividad. Este valor es el nombre que usan las funciones de orquestador para invocar esta función de actividad. Esta propiedad es opcional. Si no se especifica, se usa el nombre de la función.

La forma en que se define un desencadenador de actividad depende del modelo de programación elegido.

{
    "name": "<Name of input parameter in function signature>",
    "activity": "<Optional - name of the activity>",
    "type": "activityTrigger",
    "direction": "in"
}

module.exports = async function(context) {
    return `Hello ${context.bindings.name}!`;
};

Los enlaces de JavaScript también se pueden pasar como parámetros adicionales, por lo que la misma función podría simplificarse de la siguiente manera:

module.exports = async function(context, name) {
    return `Hello ${name}!`;
};

param($name)

"Hello $name!"

@FunctionName("SayHello")
public String sayHello(@DurableActivityTrigger(name = "name") String name) {
    return String.format("Hello %s!", name);
}

Por ejemplo, puede tomar la entrada en el enlace de actividad y enviar un mensaje a un centro de eventos mediante el enlace de salida de Event Hubs:

{
  "bindings": [
    {
      "name": "message",
      "type": "activityTrigger",
      "direction": "in"
    },
    {
      "type": "eventHub",
      "name": "outputEventHubMessage",
      "connection": "EventhubConnectionSetting",
      "eventHubName": "eh_messages",
      "direction": "out"
  }
  ]
}

module.exports = async function (context) {
    context.bindings.outputEventHubMessage = context.bindings.message;
};

Puede enlazar al cliente de orquestación mediante el atributo DurableClientAttribute (OrchestrationClientAttribute en Durable Functions v1.x).

Puede vincular al cliente de orquestación mediante la anotación @DurableClientInput.

El desencadenador de cliente duradero se define mediante el siguiente objeto JSON en la bindings matriz de function.json:

{
    "name": "<Name of input parameter in function signature>",
    "taskHub": "<Optional - name of the task hub>",
    "connectionName": "<Optional - name of the connection string app setting>",
    "type": "orchestrationClient",
    "direction": "in"
}

• taskHub : se usa en escenarios en los que varias aplicaciones de función comparten la misma cuenta de almacenamiento, pero deben aislarse entre sí. Si no se especifica, se usa el valor predeterminado de host.json . Este valor debe coincidir con el valor usado por las funciones de orquestador de destino.
• connectionName : el nombre de una configuración de aplicación que contiene una cadena de conexión de la cuenta de almacenamiento. La cuenta de almacenamiento representada por esta cadena de conexión debe ser la misma que usan las funciones de orquestador de destino. Si no se especifica, se usa la cadena de conexión de la cuenta de almacenamiento predeterminada para la aplicación de funciones.

La forma en que se define un desencadenador de cliente duradero depende del modelo de programación elegido.

{
    "name": "<Name of input parameter in function signature>",
    "taskHub": "<Optional - name of the task hub>",
    "connectionName": "<Optional - name of the connection string app setting>",
    "type": "orchestrationClient",
    "direction": "in"
}

Normalmente, se enlaza a IDurableClient (DurableOrchestrationClient en Durable Functions v1.x), lo que proporciona acceso completo a todas las API de cliente de orquestación compatibles con Durable Functions.

Normalmente, te vinculas a la clase DurableClientContext.

Debe usar el SDK específico del lenguaje para obtener acceso a un objeto de cliente.

function.json

{
  "bindings": [
    {
      "name": "input",
      "type": "queueTrigger",
      "queueName": "durable-function-trigger",
      "direction": "in"
    },
    {
      "name": "starter",
      "type": "durableClient",
      "direction": "in"
    }
  ]
}

index.js

const df = require("durable-functions");

module.exports = async function (context) {
    const client = df.getClient(context);
    return instanceId = await client.startNew("HelloWorld", undefined, context.bindings.input);
};

run.ps1

param([string] $input, $TriggerMetadata)

$InstanceId = Start-DurableOrchestration -FunctionName $FunctionName -Input $input

function.json

{
  "bindings": [
    {
      "name": "input",
      "type": "queueTrigger",
      "queueName": "durable-function-trigger",
      "direction": "in"
    },
    {
      "name": "starter",
      "type": "durableClient",
      "direction": "in"
    }
  ]
}

run.ps1

param([string]$InputData, $TriggerMetadata)

$InstanceId = Start-DurableOrchestration -FunctionName 'HelloWorld' -Input $InputData

@FunctionName("QueueStart")
public void queueStart(
        @QueueTrigger(name = "input", queueName = "durable-function-trigger", connection = "Storage") String input,
        @DurableClientInput(name = "durableContext") DurableClientContext durableContext) {
    // Orchestration input comes from the queue message content.
    durableContext.getClient().scheduleNewOrchestrationInstance("HelloWorld", input);
}

El desencadenador de entidad se configura mediante el atributo EntityTriggerAttribute .NET.

El siguiente objeto JSON define el desencadenador de entidad en la matriz bindings de function.json:

{
    "name": "<Name of input parameter in function signature>",
    "entityName": "<Optional - name of the entity>",
    "type": "entityTrigger",
    "direction": "in"
}

De forma predeterminada, el nombre de una entidad es el nombre de la función.

La forma en que se define un desencadenador de entidad depende del modelo de programación elegido.

{
    "name": "<Name of input parameter in function signature>",
    "entityName": "<Optional - name of the entity>",
    "type": "entityTrigger",
    "direction": "in"
}

Puede enlazar con el cliente de entidad mediante el atributo DurableClientAttribute de .NET en las funciones de biblioteca de clases .NET.

El cliente de entidad se define mediante el siguiente objeto JSON en la bindings matriz de function.json:

{
    "name": "<Name of input parameter in function signature>",
    "taskHub": "<Optional - name of the task hub>",
    "connectionName": "<Optional - name of the connection string app setting>",
    "type": "durableClient",
    "direction": "in"
}

• taskHub : se usa en escenarios en los que varias aplicaciones de función comparten la misma cuenta de almacenamiento, pero deben aislarse entre sí. Si no se especifica, se usa el valor predeterminado de host.json . Este valor debe coincidir con el valor usado por las funciones de entidad de destino.
• connectionName : el nombre de una configuración de aplicación que contiene una cadena de conexión de la cuenta de almacenamiento. La cuenta de almacenamiento representada por esta cadena de conexión debe ser la misma que usan las funciones de entidad de destino. Si no se especifica, se usa la cadena de conexión de la cuenta de almacenamiento predeterminada para la aplicación de funciones.

La forma en que se define un cliente de entidad depende del modelo de programación elegido.

{
    "name": "<Name of input parameter in function signature>",
    "taskHub": "<Optional - name of the task hub>",
    "connectionName": "<Optional - name of the connection string app setting>",
    "type": "durableClient",
    "direction": "in"
}