puxar pubsub a uma taxa constante?

votos
0

Existe uma maneira de impor uma taxa de sondagem constante usando o cliente google-cloud-pubsub ?. Eu quero evitar situações em que se houver aumento na taxa de publicar, a taxa de solicitação de recebimento também tendem a aumentar.

O cliente fornece FlowControlas configurações, definindo as maxOutstandingmensagens. No meu entendimento, ele define o tamanho do lote máximo durante uma operação de puxar.

Eu quero entender como criar uma taxa de tração constante, dizem mil RPS.

Publicado 02/09/2018 em 05:02
fonte usuário
Em outras línguas...                            


1 respostas

votos
1

Mensagem Flow Control pode ser usado para definir o número máximo de mensagens que estão sendo processados em um determinado momento (ou seja, a criação max_messages no caso do cliente python), que indiretamente define a taxa máxima em que as mensagens são recebidas. Enquanto ele não permite que você defina diretamente o número exato de mensagens recebidas por segundo (que dependem do tempo que leva para processar uma mensagem e o número de mensagens que estão sendo processados), deve evitar cenários onde você obtém um aumento de publicar taxa.

Se você realmente precisa para definir uma taxa em mensagens recebidas por segundo, AFAIK não é disponibilizado diretamente sobre as bibliotecas do cliente, por isso você tem que implementá-lo usando um puxão assíncrona e usando alguns temporizadores para reconhecer as mensagens em sua taxa desejada .

Respondeu 03/09/2018 em 09:53
fonte usuário

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