SubscribeOptions interface
خيارات لتكوين الأسلوب على subscribe
EventHubConsumerClient
.
على سبيل المثال،{ maxBatchSize: 20, maxWaitTimeInSeconds: 120, startPosition: { sequenceNumber: 123 } }
الخصائص
max |
عدد الأحداث المطلوب طلبها لكل دفعة |
max |
الحد الأقصى من الوقت للانتظار لإنشاء عدد الرسائل المطلوبة قبل تمرير البيانات إلى التعليمات البرمجية للمستخدم للمعالجة. إذا لم يتم توفيره، فسيتم تعيينه افتراضيا إلى 60 ثانية. |
owner |
مستوى المالك المراد استخدامه حيث يشترك هذا الاشتراك في الأقسام. |
prefetch |
عدد الأحداث المطلوبة بفارغ الصبر ووضعها في قائمة الانتظار بغض النظر عما إذا كان قد تم طلب قراءة أم لا. |
skip |
خيار لتعطيل العميل من تشغيل JSON.parse() على نص الرسالة عند تلقي الرسالة. لا ينطبق إذا تم إرسال الرسالة بقيمة أو تسلسل نوع نص AMQP. استخدم هذا الخيار عندما تفضل العمل مباشرة مع وحدات البايت الموجودة في نص الرسالة بدلا من محاولة العميل تحليلها. |
start |
موضع الحدث في قسم لبدء تلقي الأحداث من إذا لم يتم العثور على نقطة تحقق. قم بتمرير خريطة معرف القسم إلى الموضع إذا كنت ترغب في استخدام موضع بدء مختلف لكل قسم. |
tracing |
خيارات لتكوين التتبع. |
track |
يشير إلى ما إذا كان يجب على المستهلك طلب معلومات حول آخر حدث مدرج في قائمة الانتظار على القسم المرتبط به أم لا، وتتبع هذه المعلومات أثناء تلقي الأحداث. عند تعقب معلومات حول آخر حدث مدرج في قائمة الانتظار للقسم، سيحمل كل حدث تم تلقيه من خدمة مراكز الأحداث بيانات تعريف حول القسم الذي لم يكن سيحمله بخلاف ذلك. يؤدي هذا إلى كمية صغيرة من استهلاك النطاق الترددي الإضافي للشبكة الذي يكون عموما مفاضلة مواتية عند النظر في مقابل تقديم طلبات لخصائص القسم بشكل دوري باستخدام عميل 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
trackLastEnqueuedEventProperties
يشير إلى ما إذا كان يجب على المستهلك طلب معلومات حول آخر حدث مدرج في قائمة الانتظار على القسم المرتبط به أم لا، وتتبع هذه المعلومات أثناء تلقي الأحداث.
عند تعقب معلومات حول آخر حدث مدرج في قائمة الانتظار للقسم، سيحمل كل حدث تم تلقيه من خدمة مراكز الأحداث بيانات تعريف حول القسم الذي لم يكن سيحمله بخلاف ذلك. يؤدي هذا إلى كمية صغيرة من استهلاك النطاق الترددي الإضافي للشبكة الذي يكون عموما مفاضلة مواتية عند النظر في مقابل تقديم طلبات لخصائص القسم بشكل دوري باستخدام عميل Event Hub.
trackLastEnqueuedEventProperties?: boolean
قيمة الخاصية
boolean