Quickstart: إنشاء تطبيق TypeScript Durable Functions

استخدم Durable Functions، وهي ميزة في ميزة دالات Azure، لكتابة سير عمل بدون خادم ذو حالة في TypeScript. في هذا البدء السريع، تقوم باستنساخ وتشغيل تطبيق عينات يوضح نمطين شائعين من التوزيع الأوركسترالي:

• تسلسل الدوال: يستدعي الأنشطة بشكل متسلسل (طوكيو → سياتل → لندن).
• الخروج من اللاعبين/الداخل: يقوم بأنشطة المكالمات بالتوازي عبر خمس مدن، ثم يجمع النتائج.

بحلول النهاية، سيكون لديك كلا النظامين الموسيقيين يعملان محليا باستخدام محاكي Durable Task Scheduler ويمكنك عرض حالتهما في لوحة التحكم.

• قم باستنساخ وتحضير مشروع العينات لمشروع Hello Cities.
• قم بإعداد محاكي Durable Task Scheduler وAzurite للتطوير المحلي.
• شغل تطبيق الوظائف وفعل كلا التنسيقين.
• راجع حالة التوزيع والنتائج في لوحة تحكم جدولة المهام الدائمة.

المتطلبات المسبقه

• Node.js 20+ مثبت.
• دالات Azure Core Tools الإصدار الرابع أو أحدث.
• Docker لتشغيل المحاكي وAzurite.
• قم باستنساخ ><جدولة المهام المتطورة GitHub المستودع لاستخدام عينة البدء السريع.

إعداد محاكي جدولة المهام الدائمة

يوفر محاكي جدولة المهام Durable TasksScheduler بيئة تطوير محلية حتى تتمكن من اختبار التنسيقات الموسيقية دون اشتراك Azure. يحتاج مضيف الوظائف أيضا إلى Azurite للتخزين المحلي.

ابدأ كلا الحاويين:

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

نصيحة

بمجرد تشغيل المحاكي، يمكنك الوصول إلى لوحة تحكم Durable Task Scheduler لمراقبة http://localhost:8082 التنسيقات.

شغل عينة البدء السريع

1. انتقل إلى دليل نماذج Hello Cities:

   cd samples/durable-functions/typescript/HelloCities
   

2. تثبيت التبعيات وبناء المشروع:

   npm install
   npm run build
   

3. تحقق من أن الملف local.settings.json يحتوي على التكوين التالي:

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

4. شغل تطبيق الوظائف:

   func start
   

5. في محطة منفصلة، قم بتفعيل تنسيق سلسلة الدالة :

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

   تحتوي الاستجابة على روابط الحالة لنسخة التنسيق. انسخ القيمة statusQueryGetUri وشغلها للتحقق من النتيجة:

   Invoke-RestMethod -Uri $response.statusQueryGetUri
   

6. تشغيل توزيع التوزيع الموسيقي بين التوسع والدخول إلى المروحة :

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

الإنتاج المتوقع

يعيد طلب POST استجابة JSON مع عناوين الحالة. على سبيل المثال:

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

عندما تستفسر statusQueryGetUri وتكون نتائج التوزيع runtimeStatusCompletedهو ، يمكنك العثور على نتائج التحية في output الحقل. تعود التوزيع الموسيقي المتسلسل:

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

تعود التوزيع الموسيقي بين الجمهور والانضمام:

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

نصيحة

إذا runtimeStatus ظهر Running السؤال أو Pendingانتظر لحظة واسأل statusQueryGetUri مرة أخرى.

افتح لوحة تحكم جدولة المهام الدائمة على ال http://localhost:8082 لعرض حالة التوزيع وسجل التنفيذ.

افهم الشيفرة

تستخدم العينة نموذج البرمجة Node.js v4، حيث تعرف جميع الدوال في ملف واحد (src/functions/helloCities.ts).

دالة النشاط

يأخذ النشاط sayHello اسم مدينة ويعيد التحية:

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

دالات المنسق

يقوم منسق التسلسل بالاتصال sayHello بثلاث مدن:

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

يقوم الموزع الخارج/الداخل بجدول الأنشطة بالتوازي:

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

دالات العميل

تبدأ وظائف العميل التي تفعل بواسطة HTTP كل عملية تنسيق. على سبيل المثال، بادئ السلسلة:

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

التكوين

تستخدم العينة محاكي Durable Task Scheduler كخلفية للتخزين. يتم تكوين هذا في 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)"
  }
}

تنظيف الموارد

أوقف حاويات المحاكي عندما تنتهي:

docker stop dtsemulator azurite && docker rm dtsemulator azurite

الخطوات التالية

• تعرف على أنماط تطبيقات Durable Functions الشائعة.
• تعرف على Durable Functions services storages.