مشاركة عبر


durable-functions package

الفصول

AggregatedError

حدث خطأ معين عند فشل context.df.Task.all(). تحتوي رسالته على تجميع لكافة الاستثناءات التي فشلت. يجب أن يتبع التنسيق أدناه:

صادف context.df.Task.all() رسائل الخطأ أدناه:

الاسم: رسالة DurableError: فشلت دالة النشاط "ActivityA". StackTrace: <stacktrace>

الاسم: رسالة DurableError: فشلت دالة النشاط "ActivityB". StackTrace: <stacktrace>

DummyEntityContext

سياق كيان مع قيم افتراضية وهمية لتسهيل الاستنساخ/التحويط في واجهة برمجة تطبيقات Durable Functions.

DummyOrchestrationContext

سياق تزامن مع قيم افتراضية وهمية لتسهيل الاستنساخ/التحويط في واجهة برمجة تطبيقات Durable Functions.

DurableClient

عميل لبدء الاستعلام عن الأحداث وإنهائها ورفعها إلى مثيلات التنسيق والكيان.

DurableError

حدث خطأ specfic عند فشل نشاط مجدول أو مدقق فرعي. يمكن التحقق من هذا الخطأ عبر حراس instanceof لالتقاط الاستثناءات التي تطرحها مكتبة DurableJS فقط.

DurableOrchestrationContext

يوفر وظائف للتعليمات البرمجية للتطبيق الذي ينفذ عملية تزامن.

DurableOrchestrationStatus

يمثل حالة مثيل تزامن دائم.

يمكن إحضارها باستخدام DurableClient.getStatus()

EntityId

معرف فريد للكيان، يتكون من فئة الكيان ومفتاح الكيان.

EntityStateResponse

الاستجابة التي تم إرجاعها بواسطة DurableClient.readEntityState().

HttpManagementPayload

بنية البيانات التي تحتوي على نقاط نهاية HTTP لإدارة المثيل.

ManagedIdentityTokenSource

تطبيق مصدر الرمز المميز للهويات المدارة Azure.

المثال

احصل على قائمة باشتراكات Azure عن طريق استدعاء Azure Resource Manager HTTP API.

const df = require("durable-functions");

df.app.orchestration(function* (context) {
  return yield context.df.callHttp({
      method: "GET",
      url: "https://management.azure.com/subscriptions?api-version=2019-06-01",
      tokenSource: df.ManagedIdentityTokenSource("https://management.core.windows.net"),
  });
});
PurgeHistoryResult

فئة للاحتفاظ بإحصائيات حول تنفيذ محفوظات التطهير هذا. نوع الإرجاع ل DurableClient.purgeHistory()

RetryOptions

تعريف نهج إعادة المحاولة التي يمكن تمريرها كمعلمات إلى عمليات مختلفة.

الواجهات

ActivityOptions
ActivityTrigger
CallHttpOptions

عنصر الخيارات المتوفر لأساليب callHttp() في سياقات التزامن

DurableClientInput
DurableClientOptions

تكوين المدخلات والمخرجات والمعالج لدالة عميل دائم.

DurableEntityContext

يوفر وظائف للتعليمات البرمجية للتطبيق الذي ينفذ عملية كيان.

EntityContext

كائن السياق الذي تم تمريره إلى وظائف الكيان.

EntityOptions
EntityTrigger
GetStatusOptions

كائن الخيارات الذي تم تمريره إلى أسلوب getStatus() العميل

HttpDurableClientOptions

تكوين خيارات لدالة عميل دائم تم تشغيلها من قبل HTTP.

OrchestrationContext

تم تمرير كائن السياق إلى دالات التنسيق.

OrchestrationFilter

كائن خيارات تم تمريره إلى واجهات برمجة تطبيقات DurableClient لتصفية التنسيقات التي يجب تنفيذ الإجراءات عليها

OrchestrationOptions
OrchestrationTrigger
RegisteredActivityTask

مهمة Durable Functions.

RegisteredOrchestrationTask

مهمة Durable Functions.

StartNewOptions

كائن الخيارات المتوفر كوسيطة ثانية اختيارية للأسلوب client.startNew()

Task

مهمة Durable Functions.

TaskHubOptions

كائن خيارات تم تمريره إلى واجهات برمجة تطبيقات DurableClient لتحديد خصائص مركز المهام

TimerDurableClientOptions

تكوين خيارات لدالة Durable Client المشغلة من قبل المؤقت.

TimerTask

تم إرجاعه من DurableClient.createTimer(Date) إذا لم يكن الاستدعاء yield-ed. يمثل مؤقت معلق. راجع الوثائق حول المهام للحصول على مزيد من المعلومات.

يجب إكمال كافة المؤقتات المعلقة أو إلغاؤها حتى يكتمل التنسيق.

المثال

إلغاء عداد الوقت

// calculate expiration date
const timeoutTask = context.df.createTimer(expirationDate);

// do some work

if (!timeoutTask.isCompleted) {
    // An orchestration won't get marked as completed until all its scheduled
    // tasks have returned, or been cancelled. Therefore, it is important
    // to cancel timers when they're no longer needed
    timeoutTask.cancel();
}

المثال

إنشاء مهلة

const now = Date.now();
const expiration = new Date(now.valueOf()).setMinutes(now.getMinutes() + 30);

const timeoutTask = context.df.createTimer(expirationDate);
const otherTask = context.df.callActivity("DoWork");

const winner = yield context.df.Task.any([timeoutTask, otherTask]);

if (winner === otherTask) {
    // do some more work
}

if (!timeoutTask.isCompleted) {
    // An orchestration won't get marked as completed until all its scheduled
    // tasks have returned, or been cancelled. Therefore, it is important
    // to cancel timers when they're no longer needed
    timeoutTask.cancel();
}
WaitForCompletionOptions

كائن خيارات تم تمريره إلى أسلوب durableClient.waitForCompletionOrCreateCheckStatusResponse() لتحديد المهلات لطول مدة انتظار الإخراج من الدالة الدائمة ومدى تكرار التحقق من الإخراج.

النوع أسماء مستعارة

ActivityHandler
DurableClientHandler

نوع دالة معالج يتم تشغيلها بواسطة بعض المشغلات وتتلقى مثيل DurableClient كمدخل.

EntityHandler
HttpDurableClientHandler
OrchestrationHandler

نوع المولد الذي يمكن تسجيله كتزامن

RegisteredActivity
RegisteredOrchestration
TimerDurableClientHandler
TokenSource

التعدادات

OrchestrationRuntimeStatus

حالة مثيل التزامن.

الوظائف

getClient(InvocationContext)

إرجاع مثيل OrchestrationClient.

تفاصيل الوظيفة

getClient(InvocationContext)

إرجاع مثيل OrchestrationClient.

function getClient(context: InvocationContext): DurableClient

المعلمات

context
InvocationContext

كائن السياق لدالة Azure الذي يستدعي نصه هذا الأسلوب.

المرتجعات