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_conexao_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_conexao_siafi='teste',
id_relatorio='970D89D511EC423631090080EFA5BFD1',
id_conexao_mongo='teste_mongo',
banco='teste',
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.2.0.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | 2c779dd8b36bb3b5ca4b192dd2783fbde7a7bcf29cbff9efaa34e2323e0a7795 |
|
MD5 | 3bb714464c15884ab0c5cd44093dca65 |
|
BLAKE2b-256 | fb4d0119851457443f91e04676456b439be43e8cebc3b6ac67de06f66c559311 |
Close
Hashes for airflow_providers_tesouro_gerencial-1.2.0-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 5dcec30b56fa80e5a48881c1dc6012e8648e3982f1a26ce8e1f94da8662fd352 |
|
MD5 | 2b1dc77b90fd0a60b40b79d9e8081b2a |
|
BLAKE2b-256 | 16ed88da0049506b9bf5c91f69b1a1ff9fa601aa2289e3d66f9d0535ac64c5d8 |