SubscribeOptions interface

الحزمة:

@azure/event-hubs

خيارات لتكوين الأسلوب على subscribeEventHubConsumerClient. على سبيل المثال،⁧{ maxBatchSize: 20, maxWaitTimeInSeconds: 120, startPosition: { sequenceNumber: 123 } }⁩

الخصائص

maxBatchSize	عدد الأحداث المطلوب طلبها لكل دفعة
maxWaitTimeInSeconds	الحد الأقصى من الوقت للانتظار لإنشاء عدد الرسائل المطلوبة قبل تمرير البيانات إلى التعليمات البرمجية للمستخدم للمعالجة. إذا لم يتم توفيره، فسيتم تعيينه افتراضيا إلى 60 ثانية.
ownerLevel	مستوى المالك المراد استخدامه حيث يشترك هذا الاشتراك في الأقسام.
prefetchCount	عدد الأحداث المطلوبة بفارغ الصبر ووضعها في قائمة الانتظار بغض النظر عما إذا كان قد تم طلب قراءة أم لا.
skipParsingBodyAsJson	خيار لتعطيل العميل من تشغيل JSON.parse() على نص الرسالة عند تلقي الرسالة. لا ينطبق إذا تم إرسال الرسالة بقيمة أو تسلسل نوع نص AMQP. استخدم هذا الخيار عندما تفضل العمل مباشرة مع وحدات البايت الموجودة في نص الرسالة بدلا من محاولة العميل تحليلها.
startPosition	موضع الحدث في قسم لبدء تلقي الأحداث من إذا لم يتم العثور على نقطة تحقق. قم بتمرير خريطة معرف القسم إلى الموضع إذا كنت ترغب في استخدام موضع بدء مختلف لكل قسم.
tracingOptions	خيارات لتكوين التتبع.
trackLastEnqueuedEventProperties	يشير إلى ما إذا كان يجب على المستهلك طلب معلومات حول آخر حدث مدرج في قائمة الانتظار على القسم المرتبط به أم لا، وتتبع هذه المعلومات أثناء تلقي الأحداث. عند تعقب معلومات حول آخر حدث مدرج في قائمة الانتظار للقسم، سيحمل كل حدث تم تلقيه من خدمة مراكز الأحداث بيانات تعريف حول القسم الذي لم يكن سيحمله بخلاف ذلك. يؤدي هذا إلى كمية صغيرة من استهلاك النطاق الترددي الإضافي للشبكة الذي يكون عموما مفاضلة مواتية عند النظر في مقابل تقديم طلبات لخصائص القسم بشكل دوري باستخدام عميل Event Hub.

تفاصيل الخاصية

maxBatchSize

عدد الأحداث المطلوب طلبها لكل دفعة

maxBatchSize?: number

قيمة الخاصية

number

maxWaitTimeInSeconds

الحد الأقصى من الوقت للانتظار لإنشاء عدد الرسائل المطلوبة قبل تمرير البيانات إلى التعليمات البرمجية للمستخدم للمعالجة. إذا لم يتم توفيره، فسيتم تعيينه افتراضيا إلى 60 ثانية.

maxWaitTimeInSeconds?: number

قيمة الخاصية

number

ownerLevel

مستوى المالك المراد استخدامه حيث يشترك هذا الاشتراك في الأقسام.

ownerLevel?: number

قيمة الخاصية

number

prefetchCount

عدد الأحداث المطلوبة بفارغ الصبر ووضعها في قائمة الانتظار بغض النظر عما إذا كان قد تم طلب قراءة أم لا.

prefetchCount?: number

قيمة الخاصية

number

skipParsingBodyAsJson

خيار لتعطيل العميل من تشغيل JSON.parse() على نص الرسالة عند تلقي الرسالة. لا ينطبق إذا تم إرسال الرسالة بقيمة أو تسلسل نوع نص AMQP. استخدم هذا الخيار عندما تفضل العمل مباشرة مع وحدات البايت الموجودة في نص الرسالة بدلا من محاولة العميل تحليلها.

skipParsingBodyAsJson?: boolean

قيمة الخاصية

boolean

startPosition

موضع الحدث في قسم لبدء تلقي الأحداث من إذا لم يتم العثور على نقطة تحقق. قم بتمرير خريطة معرف القسم إلى الموضع إذا كنت ترغب في استخدام موضع بدء مختلف لكل قسم.

startPosition?: EventPosition | {[partitionId: string]: EventPosition}

قيمة الخاصية

EventPosition | {[partitionId: string]: EventPosition}

tracingOptions

خيارات لتكوين التتبع.

tracingOptions?: OperationTracingOptions

قيمة الخاصية

OperationTracingOptions

trackLastEnqueuedEventProperties

يشير إلى ما إذا كان يجب على المستهلك طلب معلومات حول آخر حدث مدرج في قائمة الانتظار على القسم المرتبط به أم لا، وتتبع هذه المعلومات أثناء تلقي الأحداث.

عند تعقب معلومات حول آخر حدث مدرج في قائمة الانتظار للقسم، سيحمل كل حدث تم تلقيه من خدمة مراكز الأحداث بيانات تعريف حول القسم الذي لم يكن سيحمله بخلاف ذلك. يؤدي هذا إلى كمية صغيرة من استهلاك النطاق الترددي الإضافي للشبكة الذي يكون عموما مفاضلة مواتية عند النظر في مقابل تقديم طلبات لخصائص القسم بشكل دوري باستخدام عميل Event Hub.

trackLastEnqueuedEventProperties?: boolean

قيمة الخاصية

boolean