Toggle navigation sidebar
Toggle in-page Table of Contents
async-worker
Incompatibilidades
Compatibilidade de Versões do asyncworker
Atualizando sua app Async-worker
Atualizando para 0.20.1
Atualizando para 0.20.0
Atualizando para 0.19.0
Atualizando para 0.18.0
Atualizando para 0.17.0
Atualizando para 0.16.0
Atualizando para 0.15.0
Atualizando para 0.14.0
Atualizando para 0.13.0
Atualizando para 0.12.0
Atualizando para 0.11.0
Guia de uso
Início rápido
Asyncworker App
Sobre a classe principal App
Compartilhamento de dados e inicializações assíncronas
Hooks de startup e shudtdown
Tipos de Handlers
HTTP
Registrando um novo handler HTTP
Métricas expostas para aplicações HTTP
RabbitMQ
Parametros adicionais para o decorator app.amqp.consume()
Métricas
Configurando exposição de Métricas
Tipos de Métricas
Counter
Gauge
Histograma
Métricas expostas automaticamente
Integração com Grafana
Utilitários
Timeit
Rodando uma função em um intervalo fixo de tempo
Guia de desenvolvimento
Aplicando decorators customizados a um handler HTTP
Escrevendo Testes Unitários
Como fechar uma nova versão do async-worker
Guia de uso
Guia de uso
#
Início rápido
Consumindo de uma fila no RabbitMQ
Lendo dados de um endpoint Server Side Events
Recebendo dados através de requisições HTTP
Rodando seu worker
Asyncworker App
Sobre a classe principal App
Criando uma nova App
Definindo handlers em sua App Asyncworker
Compartilhamento de dados e inicializações assíncronas
Armazenando na App
Hooks de startup e shudtdown
@app.run_on_startup
@app.run_on_shutdown
Tipos de Handlers
HTTP
Registrando um novo handler HTTP
Métodos HTTP suportados
Usando métodos não suportados pelo asyncworker
ENVs para escolher a porta e o IP onde o server http estará escutando
Handlers que são objetos callable
Handlers que recebem mais do que apenas Request
Typehints que extraem dados do Request
Recebendo parâmetros vindos do path do Request
Métricas expostas para aplicações HTTP
RabbitMQ
Parametros adicionais para o decorator app.amqp.consume()
Exemplo de valores para o campo options
Consumindo de filas de outros virtualhosts
Consumindo de filas de brokers diferentes
Uma nota sobre bulk_size e prefetch
Flush timeout
Exemplo de um código mais completo
Escolhendo, individualmente, qual ação será dada a cada mensgem recebida
Sobre AMQPConnection
Métricas
Métricas
Configurando exposição de Métricas
Formação do nome das métricas
Tipos de Métricas
Nota sobre corotinas
Uso geral dos tipos de métricas
Como usar labels
Tipos de métricas disponibilizadas pelo asyncworker
Counter
Gauge
Histograma
Métricas expostas automaticamente
Nota sobre as métricas expostas automaticamente
Métricas que são expostas por cada tipo de handler
Métricas que são independente do tipo de handler
Métricas sobre versão do Python
Métricas sobre o processo Python
Métricas sobre o Garbage Collector do Python
Integração com Grafana
Importando um dashboard
Dashboards oficiais
Exemplos
Utilitários
Timeit
Gerenciador de contexto
Decorator
Múltiplas transações
Rodando uma função em um intervalo fixo de tempo