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

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

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

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

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

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

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

يوفر محاكي جدولة المهام Durable TasksScheduler بيئة تطوير محلية حتى تتمكن من اختبار التنسيقات الموسيقية دون اشتراك Azure. يحتاج مضيف PowerShell Functions أيضا إلى 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/powershell/HelloCities

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

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

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

    func start

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

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

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

    Invoke-RestMethod -Uri $response.statusQueryGetUri

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

    $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 لعرض حالة التوزيع وسجل التنفيذ.

افهم الشيفرة

يستخدم المشروع النموذجي نموذج دالة PowerShell حيث تعيش كل دالة في مجلد فرعي خاص بها مع function.json ملف ربط وسكريبت run.ps1 .

دالة النشاط

SayHello يأخذ النشاط (SayHello/run.ps1) اسم مدينة ويعيد التحية:

param($city)

Write-Host "Saying hello to $city."
"Hello $city!"

دالات المنسق

منسق التسلسل (ChainingOrchestration/run.ps1) ينادي SayHello ثلاث مدن:

param($Context)

$output = @()
$output += Invoke-DurableActivity -FunctionName 'SayHello' -Input 'Tokyo'
$output += Invoke-DurableActivity -FunctionName 'SayHello' -Input 'Seattle'
$output += Invoke-DurableActivity -FunctionName 'SayHello' -Input 'London'

$output

يقوم منسق الخروج أو الخروج () بجدولة الأنشطة بالتوازي:FanOutFanInOrchestration/run.ps1

param($Context)

$cities = @('Tokyo', 'Seattle', 'London', 'Paris', 'Berlin')

# Fan-out: schedule all activities in parallel
$parallelTasks = @()
foreach ($city in $cities) {
    $parallelTasks += Invoke-DurableActivity -FunctionName 'SayHello' -Input $city -NoWait
}

# Fan-in: wait for all to complete
$output = Wait-ActivityFunction -Task $parallelTasks

$output

دالات العميل

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

param($Request, $TriggerMetadata)

$instanceId = Start-DurableOrchestration -FunctionName 'ChainingOrchestration'
Write-Host "Started chaining orchestration with ID = '$instanceId'."

$response = New-DurableOrchestrationCheckStatusResponse -Request $Request -InstanceId $instanceId
Push-OutputBinding -Name Response -Value $response

التكوين

تستخدم العينة محاكي Durable Task Scheduler كخلفية للتخزين. يتم تكوين هذا في host.json:

{
  "version": "2.0",
  "extensions": {
    "durableTask": {
      "hubName": "default",
      "storageProvider": {
        "type": "azureManaged",
        "connectionStringName": "DURABLE_TASK_SCHEDULER_CONNECTION_STRING"
      }
    }
  },
  "extensionBundle": {
    "id": "Microsoft.Azure.Functions.ExtensionBundle",
    "version": "[4.*, 5.0.0)"
  },
  "managedDependency": {
    "enabled": true
  }
}

إعداد managedDependency يقوم تلقائيا بتثبيت وحدات PowerShell المطلوبة المعرفة في requirements.psd1، بما في ذلك حزمة تطوير البرمجيات Durable Functions.

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

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

docker stop dtsemulator azurite && docker rm dtsemulator azurite

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

  • Last updated on