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-siafi
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.1.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | 6813df66702144cb8d9ee3272dff5ed22e0ef535a016fb62053890eb5fcd64d2 |
|
MD5 | af8a0b67b9faf58acd7645197088b969 |
|
BLAKE2b-256 | 514264a911c8d5bde4d24f3cdbaad944cf98cf8b1b13551eb463edddb31f1dcb |
Close
Hashes for airflow_providers_tesouro_gerencial-1.0.1-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 5a198f478b8ff783a9dc09a944578b3a308e934c7cc284e1e8f5db8918269da6 |
|
MD5 | dae67a7994f823716da2444438f1bfd1 |
|
BLAKE2b-256 | 62ab2eeb915e5908d4a52084c9112e88a34fda5d22884e920fe06daf6a0b1d54 |