airflow

0열

1답변

지금 몇 시간 동안 연구했지만 확인할 수 없습니다. 2017 년 10 월 현재 Windows에서 공기 흐름을 실행할 수 있습니다. Python 패키지 "pip install airflow"를 사용하여 설치했지만 초기화 할 수 없거나 버전이 Windows에서 실행될 수 없다고 가정합니다.

0열

1답변

UI 공기 흐름에서 수동으로 실행중인 기류에서 dag를 실행하는 중 오류가 발생했습니다.

공기 흐름 UI에서 수동으로 실행할 때 오류가 발생하고 테스트 및 백필 명령을 사용하여 성공적으로 실행 된 기류에 DAG를 만들었습니다. 내 문제에 대한 해결책은 무엇입니까? DAG는 LocalExecutor에서 실행됩니다. UI 공기 흐름에 오류 로그 : *** Log file isn't local. *** Fetching here: http://:87

0열

1답변

공기 흐름 - 백필에서 성공한 작업을 어떻게 무시합니까?

DAG에 새 작업을 추가 했으므로 해당 작업을 백필해야합니다. 현재 airflow backfill을 실행하면 모든 작업 (새 작업과 이전 작업)이 실행되고 이미 성공한 이전 작업은 무시됩니다. 백필에서 성공 상태의 작업을 건너 뛸 수있는 방법이 있습니까?

0열

1답변

에어 플로우 플러그인 모델보기가 보안되지 않음

에어 플로우 맞춤 보호 방법 모델보기가 플러그인 시스템을 통해 인증되지 않은 사용자로부터 추가 되었습니까? 현재 암호 보호 기능을 사용하고 있지만 플러그인에 추가 된 페이지는 로그인하지 않고도 액세스 할 수 있습니다 ...

1열

1답변

공기 흐름에서 종속 작업의 매개 변수로 문자열 목록 전달

XCom을 통해 하나의 작업에서 다른 작업으로 문자열 목록을 전달하려고 시도하지만 목록으로 해석 된 푸시 목록을 가져올 수 없습니다. . 예를 들어 , 나는 ShortCircuitOperator에서 실행되는 일부 기능 blah에서이 작업을 수행 할 때 : paths = ['gs://{}/{}'.format(bucket, obj) for obj in my_l

0열

1답변

Airflow Dags 폴더에 대해 매우 혼동이 있음

저는 Airflow에 매우 익숙합니다. 웹 사이트에 명시된대로 모든 것을 설정했습니다. 그러나 나는 dag 폴더 위치를 알아내는 것이 매우 혼란 스럽습니다. 참고 :이 폴더 내에 ** airflow.cfg (/ airflow/dags)를 구성하려면 두 개의 파일이 있어야합니다. /airflow/dags ---dag1.py ---dag2.py 하지만

0열

1답변

특정 시간에 특정 요일에 공기 흐름을 실행하는 방법은 무엇입니까?

11:00 am에 매월 2 일에 Airflow를 실행하려고하는데, 실패하고 있습니다. 내 설정은 다음과 같습니다 나는 매일에 DAG 실행할 때 default_args = { 'owner': 'airflow', 'depends_on_past': False, 'start_date': today_date, 'email': ['

0열

1답변

기류에서 캐치 업 작업에 대한 '예정 시간'을 검색하려면 어떻게해야합니까?

Airflow dag를 만들 때 주기적으로 간단한 일정을 지정합니다. 가장 일반적으로 사용하기를 기대합니다. dag = DAG('my_dag', description='this is what it does', schedule_interval='0 12 * * *', start_date=datetime(2017, 10, 1),

0열

2답변

기류 - 계단 달림 시작 시간을 받으십시오

기류에서 계기판의 실제 시작 시간을 가져올 수 있습니까? 시작 시간이란, dag의 첫 번째 작업이 실행되기 시작한 정확한 시간을 의미합니다. 실행 날짜를 얻기 위해 매크로를 사용할 수 있다는 것을 알고 있습니다. trigger_dag를 사용하여 작업을 실행하면 시작 시간이라고 부르지 만 작업이 매일 실행되는 경우 {{ execution_date }}은 ye

2열

1답변

TriggerDagRunOperator와 함께 다른 DAG를 여러 번 실행하십시오.

나는 여러 파일을 복사하는 DAG (DAG1)가 있습니다. 그런 다음 복사 된 각 파일에 대해 다른 DAG (DAG2)를 시작하려고합니다. DAG1이 실행될 때마다 복사되는 파일 수가 달라 지므로 파일을 반복 재생하고 DAG2에 적절한 매개 변수를 호출하고 싶습니다. 예 : with DAG('DAG1', description="copy files