SubscribeOptions interface
Opcje konfigurowania subscribe
metody w obiekcie EventHubConsumerClient
.
Na przykład { maxBatchSize: 20, maxWaitTimeInSeconds: 120, startPosition: { sequenceNumber: 123 } }
Właściwości
max |
Liczba zdarzeń do żądania na partię |
max |
Maksymalny czas oczekiwania na utworzenie żądanej liczby komunikatów przed przekazaniem danych do kodu użytkownika na potrzeby przetwarzania. Jeśli nie zostanie podana, wartość domyślna to 60 sekund. |
owner |
Poziom właściciela do użycia jako subskrypcja subskrybuje partycje. |
prefetch |
Liczba zdarzeń żądanych niecierpliwie i w kolejce bez względu na to, czy zażądano odczytu. |
skip |
Opcja wyłączenia klienta z uruchamiania pliku JSON.parse() w treści komunikatu podczas odbierania komunikatu. Nie dotyczy, jeśli wiadomość została wysłana z wartością typu treści amQP lub sekwencją. Użyj tej opcji, jeśli wolisz pracować bezpośrednio z bajtami obecnymi w treści komunikatu niż klient próbuje go przeanalizować. |
start |
Pozycja zdarzenia w partycji, aby rozpocząć odbieranie zdarzeń z punktu kontrolnego, jeśli nie zostanie znaleziony żaden punkt kontrolny. Przekaż mapę identyfikatora partycji, aby umieścić, jeśli chcesz użyć innej pozycji początkowej dla każdej partycji. |
tracing |
Opcje konfigurowania śledzenia. |
track |
Wskazuje, czy odbiorca powinien zażądać informacji o ostatnim zdarzeniu w kolejce na skojarzonej partycji i śledzić te informacje w miarę odbierania zdarzeń. Gdy są śledzone informacje o ostatnim zdarzeniu w kolejce partycji, każde zdarzenie odebrane z usługi Event Hubs będzie zawierać metadane dotyczące partycji, która w przeciwnym razie nie byłaby. Powoduje to niewielkie użycie dodatkowej przepustowości sieci, które jest zazwyczaj korzystnym kompromisem w przypadku okresowego podejmowania żądań dotyczących właściwości partycji przy użyciu klienta centrum zdarzeń. |
Szczegóły właściwości
maxBatchSize
Liczba zdarzeń do żądania na partię
maxBatchSize?: number
Wartość właściwości
number
maxWaitTimeInSeconds
Maksymalny czas oczekiwania na utworzenie żądanej liczby komunikatów przed przekazaniem danych do kodu użytkownika na potrzeby przetwarzania. Jeśli nie zostanie podana, wartość domyślna to 60 sekund.
maxWaitTimeInSeconds?: number
Wartość właściwości
number
ownerLevel
Poziom właściciela do użycia jako subskrypcja subskrybuje partycje.
ownerLevel?: number
Wartość właściwości
number
prefetchCount
Liczba zdarzeń żądanych niecierpliwie i w kolejce bez względu na to, czy zażądano odczytu.
prefetchCount?: number
Wartość właściwości
number
skipParsingBodyAsJson
Opcja wyłączenia klienta z uruchamiania pliku JSON.parse() w treści komunikatu podczas odbierania komunikatu. Nie dotyczy, jeśli wiadomość została wysłana z wartością typu treści amQP lub sekwencją. Użyj tej opcji, jeśli wolisz pracować bezpośrednio z bajtami obecnymi w treści komunikatu niż klient próbuje go przeanalizować.
skipParsingBodyAsJson?: boolean
Wartość właściwości
boolean
startPosition
Pozycja zdarzenia w partycji, aby rozpocząć odbieranie zdarzeń z punktu kontrolnego, jeśli nie zostanie znaleziony żaden punkt kontrolny. Przekaż mapę identyfikatora partycji, aby umieścić, jeśli chcesz użyć innej pozycji początkowej dla każdej partycji.
startPosition?: EventPosition | {[partitionId: string]: EventPosition}
Wartość właściwości
EventPosition | {[partitionId: string]: EventPosition}
tracingOptions
Opcje konfigurowania śledzenia.
tracingOptions?: OperationTracingOptions
Wartość właściwości
trackLastEnqueuedEventProperties
Wskazuje, czy odbiorca powinien zażądać informacji o ostatnim zdarzeniu w kolejce na skojarzonej partycji i śledzić te informacje w miarę odbierania zdarzeń.
Gdy są śledzone informacje o ostatnim zdarzeniu w kolejce partycji, każde zdarzenie odebrane z usługi Event Hubs będzie zawierać metadane dotyczące partycji, która w przeciwnym razie nie byłaby. Powoduje to niewielkie użycie dodatkowej przepustowości sieci, które jest zazwyczaj korzystnym kompromisem w przypadku okresowego podejmowania żądań dotyczących właściwości partycji przy użyciu klienta centrum zdarzeń.
trackLastEnqueuedEventProperties?: boolean
Wartość właściwości
boolean