Hızlı Başlangıç: JavaScript Dayanıklı İşlevler uygulaması oluşturma

JavaScript'te durum bilgisi olan sunucusuz iş akışları yazmak için Azure İşlevleri özelliği olan Dayanıklı İşlevler kullanın. Bu hızlı başlangıçta, iki yaygın düzenleme desenini gösteren bir örnek uygulamayı kopyalayıp çalıştıracaksınız:

  • İşlev zinciri: Etkinlikleri sırayla çağırır (Tokyo → Seattle → Londra).
  • Fan-out/fan-in: Beş şehirde etkinlikleri paralel olarak çağırır ve ardından sonuçları toplar.

Sonunda, Durable Task Scheduler öykünücüsüyle her iki orkestrasyonu da yerel olarak çalıştırıyor olacak ve bunların durumunu gösterge panelinde görüntüleyebileceksiniz.

  • Hello Cities örnek projesini kopyalayın ve hazırlayın.
  • Yerel geliştirme için Durable Task Scheduler öykünücüsünü ve Azurite'yi kurup yapılandırın.
  • İşlev uygulamasını çalıştırın ve her iki orkestrasyonu da tetikleyin.
  • Dayanıklı Görev Zamanlayıcı panosunda düzenleme durumunu ve çıktıyı gözden geçirin.

Prerequisites

Dayanıklı Görev Zamanlayıcı öykünücüsünü ayarlayın

Durable Task Scheduler emulator, Azure aboneliği olmadan düzenleme iş akışlarını test edebilmeniz için yerel bir geliştirme ortamı sunar. İşlevler konağı ayrıca yerel depolama için Azurite gerektirir.

Her iki kapsayıcıyı da başlatın:

docker run -d --name dtsemulator -p 8080:8080 -p 8082:8082 \
  mcr.microsoft.com/dts/dts-emulator:latest

docker run -d --name azurite -p 10000:10000 -p 10001:10001 -p 10002:10002 \
  mcr.microsoft.com/azure-storage/azurite

Tip

Öykünücü çalıştırıldıktan sonra, düzenlemeleri izlemek için adresindeki http://localhost:8082 Dayanıklı Görev Zamanlayıcı panosuna erişebilirsiniz.

Hızlı başlangıç örneğini çalıştırma

  1. Hello Cities örnek dizinine gidin:

    cd samples/durable-functions/javascript/HelloCities

  2. Bağımlılıkları yükleyin:

    npm install

  3. local.settings.json Dosyanın aşağıdaki yapılandırmayı içerdiğini doğrulayın:

    {
  "IsEncrypted": false,
  "Values": {
    "AzureWebJobsStorage": "UseDevelopmentStorage=true",
    "FUNCTIONS_WORKER_RUNTIME": "node",
    "DURABLE_TASK_SCHEDULER_CONNECTION_STRING": "Endpoint=http://localhost:8080;TaskHub=default;Authentication=None"
  }
}

  4. İşlev uygulamasını başlatın:

    func start

  5. Ayrı bir terminalde işlev zincirleme düzenlemesini tetikleyin :

    $response = Invoke-RestMethod -Method POST -Uri http://localhost:7071/api/StartChaining
$response

    Yanıt, düzenleme örneğinin durum URL'lerini içerir. statusQueryGetUri Değeri kopyalayın ve çalıştırarak sonucu denetleyin:

    Invoke-RestMethod -Uri $response.statusQueryGetUri

  6. fan-out/fan-in orkestrasyonunu tetikleyin:

    $response = Invoke-RestMethod -Method POST -Uri http://localhost:7071/api/StartFanOutFanIn
Invoke-RestMethod -Uri $response.statusQueryGetUri

Beklenen çıkış

POST isteği durum URL'lerine sahip bir JSON yanıtı döndürür. Örneğin:

{
  "id": "<instanceId>",
  "statusQueryGetUri": "http://localhost:7071/runtime/webhooks/durabletask/instances/<instanceId>?code=...",
  "sendEventPostUri": "...",
  "terminatePostUri": "...",
  "purgeHistoryDeleteUri": "..."
}

statusQueryGetUri sorguladığınızda ve orkestrasyonun runtimeStatus değeri Completed olduğunda, selamlama sonuçlarını output alanında bulabilirsiniz. Zincirleme düzenlemesi şunu döndürür:

{
  "name": "chainingOrchestration",
  "runtimeStatus": "Completed",
  "output": ["Hello Tokyo!", "Hello Seattle!", "Hello London!"]
}

Fan-out/fan-in orkestrasyonu şunu döndürür:

{
  "name": "fanOutFanInOrchestration",
  "runtimeStatus": "Completed",
  "output": ["Hello Tokyo!", "Hello Seattle!", "Hello London!", "Hello Paris!", "Hello Berlin!"]
}

Tip

runtimeStatus, Running veya Pending gösteriyorsa bir süre bekleyin ve statusQueryGetUri’ü yeniden sorgulayın.

Orkestrasyon durumunu ve yürütme geçmişini görüntülemek için http://localhost:8082 konumundaki Durable Task Scheduler panosunu açın.

Kodu anlama

Örnek, tüm işlevlerin tek bir dosyada (src/functions/helloCities.js) tanımlandığı Node.js v4 programlama modelini kullanır.

Aktivite işlevi

sayHello etkinliği bir şehir adı alır ve bir selamlama iletisi döndürür:

df.app.activity("sayHello", {
  handler: (city) => {
    return `Hello ${city}!`;
  },
});

Orchestrator işlevleri

Zincirleme orkestratör, sayHello öğesini üç şehir için sırayla çağırır:

df.app.orchestration("chainingOrchestration", function* (context) {
  const outputs = [];
  outputs.push(yield context.df.callActivity("sayHello", "Tokyo"));
  outputs.push(yield context.df.callActivity("sayHello", "Seattle"));
  outputs.push(yield context.df.callActivity("sayHello", "London"));
  return outputs;
});

fan-out/fan-in orchestrator, etkinlikleri paralel olarak planlar:

df.app.orchestration("fanOutFanInOrchestration", function* (context) {
  const cities = ["Tokyo", "Seattle", "London", "Paris", "Berlin"];

  // Fan-out: schedule all activities in parallel
  const tasks = cities.map((city) => context.df.callActivity("sayHello", city));

  // Fan-in: wait for all to complete
  const results = yield context.df.Task.all(tasks);
  return results;
});

İstemci işlevleri

HTTP ile tetiklenen istemci işlevleri her düzenlemeyi başlatır. Örneğin, zincirleme başlatıcısı:

app.http("StartChaining", {
  route: "StartChaining",
  methods: ["POST"],
  authLevel: "anonymous",
  extraInputs: [df.input.durableClient()],
  handler: async (request, context) => {
    const client = df.getClient(context);
    const instanceId = await client.startNew("chainingOrchestration");
    context.log(`Started chaining orchestration with ID = '${instanceId}'.`);
    return client.createCheckStatusResponse(request, instanceId);
  },
});

Configuration

Örnek, depolama altyapısı olarak Durable Task Scheduler emülatörünü kullanır. Bu, host.json içinde yapılandırılır:

{
  "version": "2.0",
  "logging": {
    "logLevel": {
      "DurableTask.Core": "Warning"
    }
  },
  "extensions": {
    "durableTask": {
      "hubName": "default",
      "storageProvider": {
        "type": "azureManaged",
        "connectionStringName": "DURABLE_TASK_SCHEDULER_CONNECTION_STRING"
      }
    }
  },
  "extensionBundle": {
    "id": "Microsoft.Azure.Functions.ExtensionBundle",
    "version": "[4.*, 5.0.0)"
  }
}

Kaynakları temizle

İşiniz bittiğinde emülatör kapsayıcılarını durdurun:

docker stop dtsemulator azurite && docker rm dtsemulator azurite

Sonraki Adımlar

  • Last updated on