Olá.. Poderia me tirar uma dúvida,,,. Há um plugin chamado Apache Hop Plugin para Apache Airflow, e estou em dúvida se posso alterar o conn_id passando por parametro na DAG, e se pelo código abaixo ele vai usar o que passei: Trecho do código, que inicia def __init__(self, workflow, project_name, log_level, *args, environment=None, params=None, hop_conn_id='hop_default', **kwargs):
⚠WORKSHOP 𝗔𝘀𝘁𝗿𝗼 𝗣𝘆𝘁𝗵𝗼𝗻 𝗦𝗗𝗞: 𝗗𝗲𝘀𝗲𝗻𝘃𝗼𝗹𝘃𝗲𝗻𝗱𝗼 𝗘𝗧𝗟 𝗻𝗼 𝗔𝗶𝗿𝗳𝗹𝗼𝘄 𝗽𝗮𝗿𝗮 𝗣𝗶𝗽𝗲𝗹𝗶𝗻𝗲𝘀 𝗱𝗲 𝗗𝗮𝗱𝗼𝘀 𝗠𝗼𝗱𝗲𝗿𝗻𝗼𝘀
Para mais informações acesse >>> swiy.co/D0-7
Achei incrível o Astro.... consigo fazer testes de forma rápida
Mais rápida que o próprio Airflow
Eu uso apache airflow puro no trabalho e sei como trocar essas conexões levam tempo, inclusive dão nó as vezes. Muito esse SDK
Mais um excelente conteúdo!
Astro tem conectividade com mongo db?
Olá..
Poderia me tirar uma dúvida,,,.
Há um plugin chamado Apache Hop Plugin para Apache Airflow, e estou em dúvida se posso alterar o conn_id passando por parametro na DAG, e se pelo código abaixo ele vai usar o que passei:
Trecho do código, que inicia
def __init__(self,
workflow,
project_name,
log_level,
*args,
environment=None,
params=None,
hop_conn_id='hop_default',
**kwargs):