Solucionado (ver solução)
Solucionado
(ver solução)
2
respostas

problema na execução

ao executar acontece esse erro

 python twitter_operator.py
Traceback (most recent call last):
  File "twitter_operator.py", line 47, in <module>
    with DAG(dag_id='Twitter_Test',start_time=datetime.now()) as dag:
TypeError: __init__() got an unexpected keyword argument 'start_time'
import os
import sys

sys.path.append("/mnt/f/alura-airflow/docker-airflow/datapipeline/airflow/plugins")




from airflow.models import BaseOperator,DAG,TaskInstance
from airflow.utils.decorators import apply_defaults
from hooks.twitter_hook import TwitterHook
import json
from datetime import datetime






class TwitterOperator(BaseOperator):


    def __init__(self,
                 query,
                 conn_id = None,
                 start_time = None,
                 end_time = None,
                 *args,
                 **kwargs):
        super().__init__(*args,**kwargs)
        self.query = query
        self.conn_id = conn_id
        self.start_time = start_time
        self.end_time = end_time

    def execute(self, context):
        hook = TwitterHook(query=self.query, 
                           conn_id = self.conn_id,
                           start_time=self.start_time,
                           end_time=self.end_time
                           )
        for pg in hook.run():
            print(json.dumps(pg,indent=4,sort_keys=True))


if __name__ == '__main__':
    with DAG(dag_id='Twitter_Test',start_time=datetime.now()) as dag:
        to =TwitterOperator(
            query="AluraOnline",
            task_id="test_run"
        )
        ti = TaskInstance(task=to, execution_date = datetime.now())
        to.execute(ti.get_template_context())
2 respostas
solução!

Oiii Carlos, como você está?

Peço desculpas pela demora em obter um retorno.

Este erro está sendo gerado devido ao parâmetro start_time na classe DAG, o correto é start_date, como mostro abaixo:

DAG(dag_id="TwitterTest", start_date=datetime.now())

Após a correção, tente executar novamente e verifique se obterá êxito.

Qualquer dúvida fico à disposição.

Abraços e bons estudos!

Caso este post tenha lhe ajudado, por favor, marcar como solucionado ✓.Bons Estudos!

vdd troquei o nome =D.