airflow

0열

1답변

Airflow 웹 서버에서 dag_default_view를 변경하는 방법은 무엇입니까?

공기 흐름 v1.8에서는 DAG를 클릭하면 이전에 기본값 인 "그래프"보기 대신 "트리"보기로 이동하는 UI가 변경되었습니다. 문서에 따르면,이 동작을 변경해야 설정이 라인을 추가/변경,하지만 난 어떤 성공 없었어요 : # Default DAG view. Valid values are: # tree, graph, duration, gantt, landin

0열

1답변

공기 흐름 : XCOM Inseert 중 Pickle Depth Recursion

안녕하세요 저는 PythonOperator를 사용하여 작업을 실행하고 있습니다. 이 작업은 실제로 실제로 잘 돌아갈 수 있었고 반환 된 값은 예상 한 것입니다 (API 호출의 큰 XML 출력 임). 그러나 ERROR - (builtins.RecursionError) maximum recursion depth exceeded in comparison이 표시됩

0열

1답변

공기 흐름 트리거 대행 작업자가 대상 대가를 실행하고 있지 않습니다.

대그 a와 대검 b 두 개가 있습니다. 나는 dag에서 triggerdagrun 연산자를 사용하고 triggerdagrun 연산자에서 dag id 작업 ID와 매개 변수를 전달했습니다. 두 번째 dag를 실행하는 작업이 성공적으로 실행되고 dag b의 상태가 실행 중입니다. 그러나 dag B의 작업은 시작되지 않았습니다. dag b의 스케줄 간격은 none

0열

1답변

환경 변수의 공기 흐름 구성이 작동하지 않습니다.

ENV 변수를 사용하여 연결 URL을 구성했는데 alchemy_conn 및 broker_url 등으로 미리 구성된 ami가 있습니다. 인스턴스가있는 환경에서/etc/environment에 환경 변수를 작성했습니다. amis는 airflow.cfg 파일의 속성을 재정의합니다. 파이썬 코드에서도 변수에 액세스 할 수있었습니다. 하지만, ariflow를 실행 시

2열

2답변

달의 특정 시간을 1 달로 실행하도록 예약하는 방법. 즉, 한 번

나는 한 번만 실행해야하는 dag를 실행하려고합니다. 그래서 dag 실행 간격을 '@ once'로 설정했습니다. default_args = { 'owner': 'airflow', 'depends_on_past': False, 'start_date': datetime(2017,11,13), 'email': ['[email protected]'], '

0열

1답변

Apache Airflow 클러스터의 최소 하드웨어 요구 사항

Apache Airflow 클러스터를 설정하기위한 최소 하드웨어 요구 사항은 무엇입니까? 예 : 클러스터의 노드 유형에 따라 RAM, CPU, 디스크 등. 감사

1열

1답변

공기 흐름을 통해 관리자를 통해 변수를 업로드하려면 어떤 파일 형식이 필요합니까?

에어 플로우 UI를 통해 업로드 할 변수 파일을 정의하려고하는데 업로드 할 올바른 형식을 찾기 위해 고심하고 있습니다. 나는처럼 보인다라는 파일 settings.cfg 만들었습니다 Missing file or syntax error. : 나는 공기 흐름 관리 - 통해 업로드하려고 할 때> 변수 나는 다음과 같은 메시지가 대화 my_var=test 을

0열

1답변

기류를 사용하여 하나의 워크 플로에서 별개의 작업을 별도의 컴퓨터로 실행하는 방법은 무엇입니까?

면책 조항 : 저는 (아직) Airflow의 사용자가 아니며, 오늘 발견되어 사용 사례에 적합한 지 조사하기 시작했습니다. 여러 작업을 순차적으로 (병렬이 아닌) 실행하는 하나의 데이터 처리 워크 플로가 있습니다. 그러나 일부 작업은 특정 컴퓨터에서 실행해야합니다. 기류로 관리 할 수 있습니까? 이 유스 케이스에 대해 권고 된 구현 모델은 무엇입니까?

0열

1답변

공기 흐름 웹 서버가 시작되지 않습니다

나는 github 소스를 통해 공기 흐름을 설치했습니다. 나는 로컬 executer와 함께 mysql metadb로 공기 흐름을 설정했다. 내 웹 서버를 시작하려 할 때 시작할 수 없었습니다. install.sh mkdir -p ~/home export AIRFLOW_HOME=~/airflow cd $AIRFLOW_HOME virtualenv env

0열

1답변

UI를 통해 Airflow의 작업에 매개 변수 전달

UI를 통해 Airflow의 작업에 매개 변수를 전달할 수 있습니까? AFAIK, DAG의 'params'인수는 파이썬 코드에 정의되어 있으므로 런타임에 변경할 수 없습니다.