Pubsub pull met een constante snelheid?

stemmen
0

Is er een manier om een ​​constante poll snelheid met behulp van de Google-cloud-pubsub client dwingen ?. Ik wil scenario's waarin vermijden als er piek in de publicatie-tarief, de pull verzoekratio ook de neiging om te verhogen.

De opdrachtgever biedt FlowControlinstellingen, door het instellen van de maxOutstandingberichten. Vanuit mijn begrip, het zet de maximale omvang van de partij tijdens een pull werking.

Ik wil begrijpen hoe je een constante treksnelheid te maken, laten we zeggen 1000 RPS.

De vraag is gesteld op 02/09/2018 om 05:02
bron van user
In andere talen...                            


1 antwoorden

stemmen
1

Bericht Flow Control kan worden gebruikt om het maximum aantal boodschappen op een bepaald tijdstip in behandeling ingesteld (dat wil zeggen, het instellen max_messages bij de python client), die indirect stelt de maximale snelheid waarmee berichten worden ontvangen. Hoewel het niet kunt u direct het exacte aantal ontvangen berichten per seconde (dat zou afhangen van de tijd die het kost om een bericht en het aantal berichten dat wordt verwerkt te verwerken), moet het scenario waar u een piek in krijgen te vermijden publiceren tarief.

Als je echt nodig hebt om een snelheid in ontvangen berichten per seconde te stellen, voor zover ik weet is het niet rechtstreeks toegankelijk wordt gemaakt op de client libraries, dus je zou moeten om het uit te voeren zelf met behulp van een asynchrone pull en met behulp van enkele timers om de berichten op de gewenste snelheid te erkennen .

antwoordde op 03/09/2018 om 09:53
bron van user

Cookies help us deliver our services. By using our services, you agree to our use of cookies. Learn more