Dayanıklı İşlevler bağlamaları (Azure İşlevleri)

Python v2 programlama modeli

Dayanıklı İşlevler yeni sürümde desteklenirPython v2 programlama modeli. v2 modelini kullanmak için PyPI paketiazure-functions-durable, sürümü veya sonraki bir sürüm 1.2.2 olan Dayanıklı İşlevler SDK'sını yüklemeniz gerekir. Ayrıca host.json uygulamanızın Dayanıklı İşlevler ile v2 modelini kullanmak için Uzantı Paketleri sürüm 4.x'e başvurup başvurmadığından emin olmanız gerekir.

Python deposu için Dayanıklı İşlevler SDK'sında geri bildirim ve öneriler sağlayabilirsiniz.

.NET'te işlevler yazdığınızda, orchestration tetikleyicisi OrchestrationTriggerAttribute .NET özniteliği kullanılarak yapılandırılır.

Java için ek açıklama düzenleme @DurableOrchestrationTrigger tetikleyicisini yapılandırmak için kullanılır.

Orchestrator işlevleri yazdığınızda, düzenleme tetikleyicisi function.json dosyasının bindings dizisindeki aşağıdaki JSON nesnesi tarafından tanımlanır:

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

• orchestration , istemcilerin bu orchestrator işlevinin yeni örneklerini başlatmak istediklerinde kullanması gereken düzenlemenin adıdır. Bu özellik isteğe bağlıdır. Belirtilmezse işlevin adı kullanılır.

Azure İşlevleri, Python için iki programlama modelini destekler. Düzenleme tetikleyicisi tanımlama şekliniz, seçtiğiniz programlama modeline bağlıdır.

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

Tetikleyiciyi tanımlamak için kullanılan belirli öznitelik, C# işlevlerinizi çalışırken mi yoksa yalıtılmış bir çalışan işleminde mi çalıştırdığınıza bağlıdır.

[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));
}

Düzenleyici işlevlerinin çoğu etkinlik işlevlerini çağırdığından, bir etkinlik işlevinin nasıl çağrıldığını gösteren bir "Merhaba Dünya" örneği aşağıda verilmiştir:

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;
}

Etkinlik tetikleyicisi ActivityTriggerAttribute .NET özniteliği kullanılarak yapılandırılır.

Etkinlik tetikleyicisi ek açıklama kullanılarak @DurableActivityTrigger yapılandırılır.

Etkinlik tetikleyicisi, function.json dizisinde bindings aşağıdaki JSON nesnesi tarafından tanımlanır:

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

• activity etkinliğin adıdır. Bu değer, orchestrator işlevlerinin bu etkinlik işlevini çağırmak için kullandığı addır. Bu özellik isteğe bağlıdır. Belirtilmezse işlevin adı kullanılır.

Etkinlik tetikleyicisi tanımlama şekliniz, seçtiğiniz programlama modeline bağlıdır.

{
    "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}!`;
};

JavaScript bağlamaları ek parametreler olarak da geçirilebilir, bu nedenle aynı işlev aşağıdaki gibi basitleştirilebilir:

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);
}

Örneğin, etkinlik bağlamanızın girişini alabilir ve Event Hubs çıkış bağlamasını kullanarak bir Olay Hub'ına ileti gönderebilirsiniz:

{
  "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;
};

DurableClientAttribute özniteliğini (Dayanıklı İşlevler v1.x'te OrchestrationClientAttribute) kullanarak düzenleme istemcisine bağlanabilirsiniz.

Ek açıklamayı kullanarak düzenleme istemcisine @DurableClientInput bağlanabilirsiniz.

Dayanıklı istemci tetikleyicisi, function.json dizisinde bindings aşağıdaki JSON nesnesi tarafından tanımlanır:

{
    "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 - Birden çok işlev uygulamasının aynı depolama hesabını paylaştığı ancak birbirinden yalıtılması gereken senaryolarda kullanılır. Belirtilmezse, varsayılan host.json değeri kullanılır. Bu değer, hedef düzenleyici işlevleri tarafından kullanılan değerle eşleşmelidir.
• connectionName- Depolama hesabı içeren bir uygulama ayarının adı bağlantı dizesi. Bu bağlantı dizesi temsil edilen depolama hesabı, hedef düzenleyici işlevleri tarafından kullanılanla aynı olmalıdır. Belirtilmezse, işlev uygulaması için varsayılan depolama hesabı bağlantı dizesi kullanılır.

Dayanıklı bir istemci tetikleyicisi tanımlama şekliniz, seçtiğiniz programlama modeline bağlıdır.

{
    "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"
}

Genellikle Dayanıklı İşlevler tarafından desteklenen tüm düzenleme istemci API'lerine tam erişim sağlayan IDurableClient'a (Dayanıklı İşlevler v1.x'te DurableOrchestrationClient) bağlanırsınız.

Genellikle sınıfına DurableClientContext bağlanırsınız.

İstemci nesnesine erişim elde etmek için dile özgü SDK'sını kullanmanız gerekir.

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);
}

Varlık tetikleyicisi EntityTriggerAttribute .NET özniteliği kullanılarak yapılandırılır.

Varlık tetikleyicisi, function.json dizisinde bindings aşağıdaki JSON nesnesi tarafından tanımlanır:

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

Varsayılan olarak, bir varlığın adı işlevin adıdır.

Varlık tetikleyicisi tanımlama şekliniz, seçtiğiniz programlama modeline bağlıdır.

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

.NET sınıf kitaplığı işlevlerinde DurableClientAttribute .NET özniteliğini kullanarak varlık istemcisine bağlanabilirsiniz.

Varlık istemcisi, function.json dizisinde bindings aşağıdaki JSON nesnesi tarafından tanımlanır:

{
    "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 - Birden çok işlev uygulamasının aynı depolama hesabını paylaştığı ancak birbirinden yalıtılması gereken senaryolarda kullanılır. Belirtilmezse, varsayılan host.json değeri kullanılır. Bu değer, hedef varlık işlevleri tarafından kullanılan değerle eşleşmelidir.
• connectionName- Depolama hesabı içeren bir uygulama ayarının adı bağlantı dizesi. Bu bağlantı dizesi temsil edilen depolama hesabı, hedef varlık işlevleri tarafından kullanılanla aynı olmalıdır. Belirtilmezse, işlev uygulaması için varsayılan depolama hesabı bağlantı dizesi kullanılır.

Varlık istemcisini tanımlama şekliniz, seçtiğiniz programlama modeline bağlıdır.

{
    "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"
}