Olá, pessoal!
Preciso de uma mãozinha quanto ao meu código, já li, reli, parei, voltei e o erro continua, por mais que seja de sintaxe, não tenho achado o problema. Segue print e código até a linha 19.
from airflow.providers.http.hooks.http import HttpHook # Hook especifico para API
import requests
import json
class TwitterHook(HttpHook): # Herdo um ganho
def __init__(self, query, conn_id = None, start_time = None, end_time = None): # a pesquisa e a conexao que vamos fazer
self.query = query
self.conn_id = conn_id or "twitter_default" # se nao tiver conn_id, twitter_default
self.start_time = start_time
self.end_time = end_time
super().__init__(http_conn_id=self.conn_id)
def create_url(self):
query = self.query
tweet_fields = "tweet.fields=author_id,conversation_id,created_at,id,in_reply_to_user_id,public_metrics,text"
user_fields = "expansions=author_id&user.fields=id,name,username,created_at"
start_time = (
f"&start_time={self.start_time}"
if self.start_time
else ""
)Poderiam me ajudar, por favor?
