EventHubBufferedProducerClientOptions interface
Popisuje možnosti, které lze poskytnout při vytváření .EventHubBufferedProducerClient
- Extends
Vlastnosti
enable |
Určuje, jestli má eventHubProducerClient povolit idempotentní publikování do oddílů centra událostí. Pokud je povoleno, producent bude moci publikovat pouze přímo do oddílů; nebude moct publikovat do brány služby Event Hubs pro automatické směrování oddílů ani nebude moct použít klíč oddílu. Výchozí hodnota: false |
max |
Celkový počet událostí, které lze v daném okamžiku pro daný oddíl ukládat do vyrovnávací paměti pro publikování. Výchozí hodnota: 1500 |
max |
Doba čekání na zařazení nové události do fronty ve vyrovnávací paměti před publikováním částečně úplné dávky. Výchozí hodnota: 1 sekunda. |
on |
Obslužná rutina, která se má volat, když se dávka nepodaří publikovat. |
on |
Obslužná rutina, která se má volat po úspěšném publikování dávky. |
Zděděné vlastnosti
custom |
Vlastní koncový bod, který se použije při připojování ke službě Event Hubs. To může být užitečné, když vaše síť neumožňuje připojení ke standardní adrese Azure Event Hubs koncového bodu, ale umožňuje připojení prostřednictvím zprostředkovatele. Příklad: "https://my.custom.endpoint:100/" |
identifier | Jedinečný název sloužící k identifikaci klienta. Pokud není zadaný, jako identifikátor se použije identifikátor GUID. |
retry |
Možnosti konfigurace zásad opakování pro všechny operace na klientovi
Příkladem je |
user |
Hodnota, která je připojena k integrovanému řetězci uživatelského agenta, který se předává službě Event Hubs. |
web |
Možnosti konfigurace channelingu připojení AMQP přes webové sokety. |
Podrobnosti vlastnosti
enableIdempotentRetries
Určuje, jestli má eventHubProducerClient povolit idempotentní publikování do oddílů centra událostí. Pokud je povoleno, producent bude moci publikovat pouze přímo do oddílů; nebude moct publikovat do brány služby Event Hubs pro automatické směrování oddílů ani nebude moct použít klíč oddílu. Výchozí hodnota: false
enableIdempotentRetries?: boolean
Hodnota vlastnosti
boolean
maxEventBufferLengthPerPartition
Celkový počet událostí, které lze v daném okamžiku pro daný oddíl ukládat do vyrovnávací paměti pro publikování.
Výchozí hodnota: 1500
maxEventBufferLengthPerPartition?: number
Hodnota vlastnosti
number
maxWaitTimeInMs
Doba čekání na zařazení nové události do fronty ve vyrovnávací paměti před publikováním částečně úplné dávky.
Výchozí hodnota: 1 sekunda.
maxWaitTimeInMs?: number
Hodnota vlastnosti
number
onSendEventsErrorHandler
Obslužná rutina, která se má volat, když se dávka nepodaří publikovat.
onSendEventsErrorHandler: (ctx: OnSendEventsErrorContext) => void
Hodnota vlastnosti
(ctx: OnSendEventsErrorContext) => void
onSendEventsSuccessHandler
Obslužná rutina, která se má volat po úspěšném publikování dávky.
onSendEventsSuccessHandler?: (ctx: OnSendEventsSuccessContext) => void
Hodnota vlastnosti
(ctx: OnSendEventsSuccessContext) => void
Podrobnosti zděděných vlastností
customEndpointAddress
Vlastní koncový bod, který se použije při připojování ke službě Event Hubs. To může být užitečné, když vaše síť neumožňuje připojení ke standardní adrese Azure Event Hubs koncového bodu, ale umožňuje připojení prostřednictvím zprostředkovatele.
Příklad: "https://my.custom.endpoint:100/"
customEndpointAddress?: string
Hodnota vlastnosti
string
identifier
Jedinečný název sloužící k identifikaci klienta. Pokud není zadaný, jako identifikátor se použije identifikátor GUID.
identifier?: string
Hodnota vlastnosti
string
Zděděno zEventHubClientOptions.identifier
retryOptions
Možnosti konfigurace zásad opakování pro všechny operace na klientovi
Příkladem je { "maxRetries": 4 }
nebo { "maxRetries": 4, "retryDelayInMs": 30000 }
.
retryOptions?: RetryOptions
Hodnota vlastnosti
Zděděno zEventHubClientOptions.retryOptions
userAgent
Hodnota, která je připojena k integrovanému řetězci uživatelského agenta, který se předává službě Event Hubs.
userAgent?: string
Hodnota vlastnosti
string
webSocketOptions
Možnosti konfigurace channelingu připojení AMQP přes webové sokety.
webSocketOptions?: WebSocketOptions