Provider do Airflow para comunicação com Tesouro Gerencial
Project description
airflow-providers-tesouro-gerencial
Provider do Airflow para comunicação com Tesouro Gerencial.
Instalação
pip install airflow-providers-tesouro-gerencial
Conteúdo
-
Hook para conexão com Tesouro Gerencial, que contém métodos para:
- Entrada e saída de contexto (clásula
with
), inicializando e encerrando sessão no Tesouro Gerencial - Execução e exportação de relatório
- Entrada e saída de contexto (clásula
-
Transfers que carregam relatórios do Tesouro Gerencial para:
- Arquivo local;
- Banco MongoDB
Exemplo de Uso
Transferência de relatório para arquivo local:
from datetime import datetime, timedelta
from airflow.decorators import dag
from airflow.providers.tesouro_gerencial.transfers.relatorio_para_arquivo import RelatorioParaArquivo
@dag(schedule_interval=None, start_date=datetime(2021, 1, 1))
def teste_tesouro_gerencial():
teste = RelatorioParaArquivo(
task_id='teste1',
id_conta_siafi='teste',
id_relatorio='970A89D511EC923631090080EFC5BFD1',
caminho_arquivo='/tmp/tg.xlsx',
respostas_prompts_valor=['622110000', '622120000'],
retries=10,
retry_delay=timedelta(minutes=2)
)
minha_dag = teste_tesouro_gerencial()
Transferência para banco MongoDB
from datetime import datetime, timedelta
from airflow.decorators import dag
from airflow.providers.tesouro_gerencial.transfers.relatorio_para_mongo import RelatorioParaMongo
@dag(schedule_interval=None, start_date=datetime(2021, 1, 1))
def teste_tesouro_gerencial():
teste = RelatorioParaMongo(
task_id='teste2',
id_conta_siafi='teste',
id_relatorio='970D89D511EC423631090080EFA5BFD1',
id_conexao_mongo='teste_mongo',
nome_colecao='teste',
respostas_prompts_valor=['622110000', '622120000'],
truncar_colecao=True,
retries=10,
retry_delay=timedelta(minutes=2)
)
minha_dag = teste_tesouro_gerencial()
Project details
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Close
Hashes for airflow-providers-tesouro-gerencial-1.0.3.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | 5b2121f668ffac736fa3a36b11d38151109fa184f30629da92e0db7b6f066a07 |
|
MD5 | 7e6f2f0281908a233f79c1326d3df867 |
|
BLAKE2b-256 | 5e04532e2d374141737a41366f3fd7111074e09df9987263642991458a7617a9 |
Close
Hashes for airflow_providers_tesouro_gerencial-1.0.3-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 5f9d439f70591c37ba7e7aac55ef3109b7361dff2803a65a8da9bd75c3f12f4f |
|
MD5 | 2038f29023c396f34f488880e46d9ef4 |
|
BLAKE2b-256 | 3687d5fb5953a90f62d3d45c134c893db7e5c0ff27745c135a6b0d92de72cf2b |