EventHubBufferedProducerClientOptions interface

يصف الخيارات التي يمكن توفيرها أثناء إنشاء EventHubBufferedProducerClient.

يمتد

الخصائص

enableIdempotentRetries

يشير إلى ما إذا كان يجب على EventHubProducerClient تمكين النشر غير الفعال إلى أقسام Event Hub أم لا. إذا تم تمكينه، فلن يتمكن المنتج إلا من النشر مباشرة إلى الأقسام؛ لن يتمكن من النشر إلى بوابة مراكز الأحداث لتوجيه القسم التلقائي ولن يتمكن من استخدام مفتاح قسم. الافتراضي: False

maxEventBufferLengthPerPartition

العدد الإجمالي للأحداث التي يمكن تخزينها مؤقتا للنشر في وقت معين لقسم معين.

الافتراضي: 1500

maxWaitTimeInMs

مقدار الوقت الذي يجب انتظاره حتى يتم وضع حدث جديد في قائمة الانتظار في المخزن المؤقت قبل نشر دفعة كاملة جزئيا.

الافتراضي: ثانية واحدة.

onSendEventsErrorHandler

المعالج الذي يجب الاتصال به عندما تفشل الدفعة في النشر.

onSendEventsSuccessHandler

المعالج المراد استدعائه بمجرد نشر دفعة بنجاح.

الخصائص الموروثة

customEndpointAddress

نقطة نهاية مخصصة لاستخدامها عند الاتصال بخدمة مراكز الأحداث. يمكن أن يكون هذا مفيدا عندما لا تسمح شبكتك بالاتصال بعنوان نقطة نهاية Azure Event Hubs القياسي، ولكنها تسمح بالاتصال من خلال وسيط.

مثال: "https://my.custom.endpoint:100/"؛

identifier

اسم فريد يستخدم لتعريف العميل. إذا لم يتم توفيره، فسيتم استخدام GUID كمعرف

retryOptions

خيارات لتكوين نهج إعادة المحاولة لجميع العمليات على العميل. على سبيل المثال، { "maxRetries": 4 } أو { "maxRetries": 4, "retryDelayInMs": 30000 }.

userAgent

القيمة التي يتم إلحاقها بسلسلة عامل المستخدم المضمنة التي يتم تمريرها إلى خدمة مراكز الأحداث.

webSocketOptions

خيارات لتكوين قناة اتصال 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

موروث منEventHubClientOptions.customEndpointAddress

identifier

اسم فريد يستخدم لتعريف العميل. إذا لم يتم توفيره، فسيتم استخدام GUID كمعرف

identifier?: string

قيمة الخاصية

string

موروث منEventHubClientOptions.identifier

retryOptions

خيارات لتكوين نهج إعادة المحاولة لجميع العمليات على العميل. على سبيل المثال، { "maxRetries": 4 } أو { "maxRetries": 4, "retryDelayInMs": 30000 }.

retryOptions?: RetryOptions

قيمة الخاصية

موروث منEventHubClientOptions.retryOptions

userAgent

القيمة التي يتم إلحاقها بسلسلة عامل المستخدم المضمنة التي يتم تمريرها إلى خدمة مراكز الأحداث.

userAgent?: string

قيمة الخاصية

string

موروث منEventHubClientOptions.userAgent

webSocketOptions

خيارات لتكوين قناة اتصال AMQP عبر مآخذ ويب.

webSocketOptions?: WebSocketOptions

قيمة الخاصية

موروث منEventHubClientOptions.webSocketOptions