EventHubBufferedProducerClientOptions interface
يصف الخيارات التي يمكن توفيرها أثناء إنشاء EventHubBufferedProducerClient
.
- يمتد
الخصائص
enable |
يشير إلى ما إذا كان يجب على EventHubProducerClient تمكين النشر غير الفعال إلى أقسام Event Hub أم لا. إذا تم تمكينه، فلن يتمكن المنتج إلا من النشر مباشرة إلى الأقسام؛ لن يتمكن من النشر إلى بوابة مراكز الأحداث لتوجيه القسم التلقائي ولن يتمكن من استخدام مفتاح قسم. الافتراضي: False |
max |
العدد الإجمالي للأحداث التي يمكن تخزينها مؤقتا للنشر في وقت معين لقسم معين. الافتراضي: 1500 |
max |
مقدار الوقت الذي يجب انتظاره حتى يتم وضع حدث جديد في قائمة الانتظار في المخزن المؤقت قبل نشر دفعة كاملة جزئيا. الافتراضي: ثانية واحدة. |
on |
المعالج الذي يجب الاتصال به عندما تفشل الدفعة في النشر. |
on |
المعالج المراد استدعائه بمجرد نشر دفعة بنجاح. |
الخصائص الموروثة
custom |
نقطة نهاية مخصصة لاستخدامها عند الاتصال بخدمة مراكز الأحداث. يمكن أن يكون هذا مفيدا عندما لا تسمح شبكتك بالاتصال بعنوان نقطة نهاية Azure Event Hubs القياسي، ولكنها تسمح بالاتصال من خلال وسيط. مثال: "https://my.custom.endpoint:100/"؛ |
identifier | اسم فريد يستخدم لتعريف العميل. إذا لم يتم توفيره، فسيتم استخدام GUID كمعرف |
retry |
خيارات لتكوين نهج إعادة المحاولة لجميع العمليات على العميل.
على سبيل المثال، |
user |
القيمة التي يتم إلحاقها بسلسلة عامل المستخدم المضمنة التي يتم تمريرها إلى خدمة مراكز الأحداث. |
web |
خيارات لتكوين قناة اتصال AMQP عبر مآخذ ويب. |
تفاصيل الخاصية
enableIdempotentRetries
يشير إلى ما إذا كان يجب على EventHubProducerClient تمكين النشر غير الفعال إلى أقسام Event Hub أم لا. إذا تم تمكينه، فلن يتمكن المنتج إلا من النشر مباشرة إلى الأقسام؛ لن يتمكن من النشر إلى بوابة مراكز الأحداث لتوجيه القسم التلقائي ولن يتمكن من استخدام مفتاح قسم. الافتراضي: False
enableIdempotentRetries?: boolean
قيمة الخاصية
boolean
maxEventBufferLengthPerPartition
العدد الإجمالي للأحداث التي يمكن تخزينها مؤقتا للنشر في وقت معين لقسم معين.
الافتراضي: 1500
maxEventBufferLengthPerPartition?: number
قيمة الخاصية
number
maxWaitTimeInMs
مقدار الوقت الذي يجب انتظاره حتى يتم وضع حدث جديد في قائمة الانتظار في المخزن المؤقت قبل نشر دفعة كاملة جزئيا.
الافتراضي: ثانية واحدة.
maxWaitTimeInMs?: number
قيمة الخاصية
number
onSendEventsErrorHandler
المعالج الذي يجب الاتصال به عندما تفشل الدفعة في النشر.
onSendEventsErrorHandler: (ctx: OnSendEventsErrorContext) => void
قيمة الخاصية
(ctx: OnSendEventsErrorContext) => void
onSendEventsSuccessHandler
المعالج المراد استدعائه بمجرد نشر دفعة بنجاح.
onSendEventsSuccessHandler?: (ctx: OnSendEventsSuccessContext) => void
قيمة الخاصية
(ctx: OnSendEventsSuccessContext) => void
تفاصيل الخاصية الموروثة
customEndpointAddress
نقطة نهاية مخصصة لاستخدامها عند الاتصال بخدمة مراكز الأحداث. يمكن أن يكون هذا مفيدا عندما لا تسمح شبكتك بالاتصال بعنوان نقطة نهاية Azure Event Hubs القياسي، ولكنها تسمح بالاتصال من خلال وسيط.
مثال: "https://my.custom.endpoint:100/"؛
customEndpointAddress?: string
قيمة الخاصية
string
identifier
اسم فريد يستخدم لتعريف العميل. إذا لم يتم توفيره، فسيتم استخدام GUID كمعرف
identifier?: string
قيمة الخاصية
string
موروث منEventHubClientOptions.identifier
retryOptions
خيارات لتكوين نهج إعادة المحاولة لجميع العمليات على العميل.
على سبيل المثال، { "maxRetries": 4 }
أو { "maxRetries": 4, "retryDelayInMs": 30000 }
.
retryOptions?: RetryOptions
قيمة الخاصية
userAgent
القيمة التي يتم إلحاقها بسلسلة عامل المستخدم المضمنة التي يتم تمريرها إلى خدمة مراكز الأحداث.
userAgent?: string
قيمة الخاصية
string
موروث منEventHubClientOptions.userAgent
webSocketOptions
خيارات لتكوين قناة اتصال AMQP عبر مآخذ ويب.
webSocketOptions?: WebSocketOptions