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.2.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | 80bc07e04686d6921348851d571860febe5bc1266a3d351dc216cd3d0a9c32aa |
|
MD5 | e911bb3b48668139d0f9cfeb1da1ca93 |
|
BLAKE2b-256 | 715acf6a40f941e1629c204475bb4459761d621e27d5a0bfa4bb0749e3897c95 |
Close
Hashes for airflow_providers_tesouro_gerencial-1.0.2-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 47b37d6e6b3e62c84e3d6626dee01f084addb5316cf596536f6427a0385517e1 |
|
MD5 | 3059b107303d55cc6615223817c02ada |
|
BLAKE2b-256 | 4f330daf9234072e82416acd349a760481d8e0485534fd9e0a8d55c93a4cc283 |