Size: a a a

2020 September 25

А

Анатоли in Airflow
почему неправильно  синтаксис
источник

PA

Panchenko Andrey in Airflow
ну как можно сказать не видя этого словаря?
источник

SG

Sergey Gavrilov in Airflow
catchup-False
источник

SG

Sergey Gavrilov in Airflow
интаксическая ошибка
источник

SG

Sergey Gavrilov in Airflow
Там должно быть =
источник

SG

Sergey Gavrilov in Airflow
start.task и start_task это вообще абсолютно разные вещи
источник

SG

Sergey Gavrilov in Airflow
Попробуйте начать с азов Python-а на каких-нибудь бесплатных курсах
источник

А

Анатоли in Airflow
может отступы полный текст привожу
from datetime import datetime, timedelta
from airflow import DAG
from airflow.hooks.postgres_hook import PostgresHook
from airflow.operators.dummy_operator  import  DummyOperator
from airflow.operators.python_operator import PythonOperator


defaults_args = {
       'owner':'airflow',
       'start_date':  datetime(2018, 11, 5, 10, 00, 00),
       'retries':1,
       'retry_delay': timedelta(minutes= 1)
}

def get_activated_sources():
       request = "SELECT * FROM users"
       pg_hook = PostgresHook(postgre_conn_id="postgres", schema="postgres")
       connection = pg_hook.get_conn()
       cursor = connection.cursor()
       cursor.execute(request)
       sources = cursor.fetchall
       for source in sources:
               print( "Source: {0}} activated {1}".format(source[0], source[1]))
       return sources

with DAG('hook_dag',
    default_args=default_args,
    schedule_interval= '@once',
    catchup=False) as dag:

       start.task = DummyOperator(task_id='start_task')
       hook.task = PythonOperator (task_id='hook_task', python_callable=get_activated_sources)
       start_task >> hook_task
источник

M

Mikhail in Airflow
Анатоли
может отступы полный текст привожу
from datetime import datetime, timedelta
from airflow import DAG
from airflow.hooks.postgres_hook import PostgresHook
from airflow.operators.dummy_operator  import  DummyOperator
from airflow.operators.python_operator import PythonOperator


defaults_args = {
       'owner':'airflow',
       'start_date':  datetime(2018, 11, 5, 10, 00, 00),
       'retries':1,
       'retry_delay': timedelta(minutes= 1)
}

def get_activated_sources():
       request = "SELECT * FROM users"
       pg_hook = PostgresHook(postgre_conn_id="postgres", schema="postgres")
       connection = pg_hook.get_conn()
       cursor = connection.cursor()
       cursor.execute(request)
       sources = cursor.fetchall
       for source in sources:
               print( "Source: {0}} activated {1}".format(source[0], source[1]))
       return sources

with DAG('hook_dag',
    default_args=default_args,
    schedule_interval= '@once',
    catchup=False) as dag:

       start.task = DummyOperator(task_id='start_task')
       hook.task = PythonOperator (task_id='hook_task', python_callable=get_activated_sources)
       start_task >> hook_task
у вас проблема не с airflow, а с синтаксисом питона
источник

M

Mikhail in Airflow
прочитайте книжку, посмотрите бесплатный курс на ютьюбе
источник

А

Анатоли in Airflow
у человека работает этот код
LearnCodeAndScale
Apache Airflow | Getting Results From PostgreSQL Using Hooks
источник

M

Mikhail in Airflow
у какого?
источник

M

Mikhail in Airflow
этот код не может работать, там полная каша в этом коде
источник

M

Mikhail in Airflow
он синтаксически неверный
источник

SG

Sergey Gavrilov in Airflow
Не может работать никак, никогда и нигде
источник

А

Анатоли in Airflow
youtube канал MarcLamberti привожу
https://www.youtube.com/watch?v=ATUARuFh3JQ
источник

M

Mikhail in Airflow
источник

M

Mikhail in Airflow
вы пытаетесь переписывать код с экрана, не разбираясь что он делает
источник

M

Mikhail in Airflow
причем с ошибками переписываете
источник

M

Mikhail in Airflow
начните с основ языка
источник