공기 흐름에서 jdbc 연결을 설정할 수 없습니다. 오류 클래스를 찾을 수 없습니다. 내 연결 자격 증명이 모두 올바른지 내가 SQLWorkbenchJ와 연결할 수 있습니다 테스트 할 때 여기에 을 공기 흐름에 내가 나타나는 오류입니다 : 내 연결은 다음과 같습니다. 또한 나는 다른 redshift jdbc 드라이버와 클래스 이름을 시도했다. /Users/
Kubernetes에서 Airflow를 테스트하려고합니다. 스케줄러, 작업자, 대기열 및 웹 서버는 모두 다른 배포 환경에 있으며 셀러 리 실행 프로그램을 사용하여 작업을 실행하고 있습니다. 스케줄러가 작업을 대기열에 넣을 수 없다는 점을 제외하면 모든 것이 잘 작동합니다. 기류는 웹 UI 나 CLI에서 수동으로 실행할 때 내 작업을 잘 실행할 수 있지만
DC/OS에서 Airflow를 사용하여 '도커 실행'작업을 예약하려고합니다. 이를 위해서는 공기 흐름이 포함 된 도커 컨테이너에서 도커 컨테이너를 시작할 수 있어야합니다. 나는 OSX에서이 작업을 할 수 있어요하지만 바로 실행 : docker run \
-p 8080:8080 \
-v /var/run/docker.sock:/var/run/
작업/dag 시간 제한을 없음으로 설정하고 수동으로 실행중인 트리거를 사용하여 끝날 수없는 작업 (즉, 스트림 데이터를 소비하는 무조건적인 루프가있는 작업)을 정의하기 위해 기류 대구를 사용할 수 있습니까? 공기 흐름 모니터링을 끝내지 않으면 문제가 발생합니까? 감사합니다.
지난 며칠 동안 Airflow를 ETL 워크 플로의 대체 도구로 평가했으며 Airflow에서 DAG의 이름이 바뀌면 흥미로운 동작을 발견했습니다. 나는 파일의 DAG가 hello_world.py dag = DAG('hello_world', description='Simple DAG',
schedule_interval='0 12 * * *',
웹 서버가 하나의 컴퓨터에서 실행되고 스케줄러가 다른 컴퓨터에서 실행되도록 기류를 설정 중입니다. 두 제품 모두 동일한 MySQL 메타 스토어 데이터베이스를 공유합니다. 두 인스턴스 모두 로그에 오류없이 나타나지만 스케줄러는 웹 UI를 통해 DAG를 수동으로 트리거하여 만든 DAG 실행을 선택하지 않습니다. MYSQL의 dag_run 테이블이 몇 가지 항목
안녕하세요 Airflow입니다. 나는 아래와 같이 txt 파일의 목록을 저장하는 간단한 코드를 작성 : 나는 웹 서버 인터페이스를 사용할 때 from airflow.models import DAG
from airflow.operators.python_operator import PythonOperator
import datetime
DAG = DAG