Mulai Cepat: Membuat aplikasi typeScript Durable Functions

Gunakan Durable Functions, fitur Azure Functions, untuk menulis alur kerja tanpa server stateful di TypeScript. Dalam panduan singkat ini, Anda mengklon dan menjalankan aplikasi contoh yang menunjukkan dua pola orkestrasi umum:

  • Penautan fungsi: Memanggil aktivitas secara berurutan (Tokyo → Seattle → London).
  • Fan-out/fan-in: Memanggil aktivitas secara paralel di lima kota, lalu menggabungkan hasilnya.

Pada akhirnya, Anda akan memiliki kedua orkestrasi yang berjalan secara lokal dengan emulator Durable Task Scheduler dan dapat melihat statusnya di dasbor.

  • Kloning dan siapkan proyek sampel Hello Cities.
  • Siapkan emulator Durable Task Scheduler dan Azurite untuk pengembangan lokal.
  • Jalankan aplikasi fungsi dan picu kedua orkestrasi.
  • Tinjau status orkestrasi dan output di dasbor Durable Task Scheduler.

Prasyarat

Menyiapkan emulator "Durable Task Scheduler"

Emulator Task Scheduler Durable menyediakan lingkungan pengembangan lokal sehingga Anda dapat menguji orkestrasi tanpa langganan Azure. Host Functions juga memerlukan Azurite untuk penyimpanan lokal.

Mulai kedua kontainer:

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

Setelah emulator berjalan, Anda dapat mengakses dasbor Durable Task Scheduler di http://localhost:8082 untuk memantau orkestrasi.

Jalankan contoh memulai cepat

  1. Navigasikan ke direktori sampel Hello Cities:

    cd samples/durable-functions/typescript/HelloCities

  2. Instal dependensi dan bangun proyek:

    npm install
npm run build

  3. Verifikasi bahwa local.settings.json file berisi konfigurasi berikut:

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

  4. Mulai aplikasi fungsi:

    func start

  5. Di terminal terpisah, jalankan orkestrasi rantai fungsi:

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

    Respons berisi URL status untuk instans orkestrasi. statusQueryGetUri Salin nilai dan jalankan untuk memeriksa hasilnya:

    Invoke-RestMethod -Uri $response.statusQueryGetUri

  6. Picu orkestrasi fan-out/fan-in:

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

Output yang diharapkan

Permintaan POST mengembalikan respons JSON dengan URL status. Contohnya:

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

Saat Anda mengkueri statusQueryGetUri dan orkestrasi runtimeStatus adalah Completed, Anda bisa menemukan hasil salam di output bidang . Orkestrasi perangkaian mengembalikan:

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

Orkestrasi fan-out/fan-in mengembalikan:

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

Tip

Jika runtimeStatus memperlihatkan Running atau Pending, tunggu sebentar dan kueri lagi statusQueryGetUri .

Buka dasbor Durable Task Scheduler di http://localhost:8082 untuk melihat status orkestrasi dan riwayat eksekusi.

Memahami kode

Sampel menggunakan model pemrograman Node.js v4, di mana semua fungsi didefinisikan dalam satu file (src/functions/helloCities.ts).

Fungsi aktivitas

Aktivitas sayHello ini mengambil nama kota dan menghasilkan salam:

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

Fungsi orkestrator

orkestrator berantai memanggil sayHello secara berurutan untuk tiga kota:

const chainingOrchestrator: OrchestrationHandler = function* (
  context: OrchestrationContext
) {
  const outputs: string[] = [];
  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;
};
df.app.orchestration("chainingOrchestration", chainingOrchestrator);

Orkestrator fan-out/fan-in menjadwalkan aktivitas secara paralel:

const fanOutFanInOrchestrator: OrchestrationHandler = function* (
  context: OrchestrationContext
) {
  const cities: string[] = ["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: string[] = yield context.df.Task.all(tasks);
  return results;
};
df.app.orchestration("fanOutFanInOrchestration", fanOutFanInOrchestrator);

Fungsi klien

Fungsi klien yang dipicu HTTP memulai setiap orkestrasi. Misalnya, permulaan rantai:

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

Konfigurasi

Sampel menggunakan emulator Durable Task Scheduler sebagai backend penyimpanannya. Ini dikonfigurasi dalam host.json:

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

Membersihkan sumber daya

Hentikan kontainer emulator setelah Anda selesai:

docker stop dtsemulator azurite && docker rm dtsemulator azurite

Langkah berikutnya

  • Last updated on