Плагин импорта воздушного потока - PullRequest
Новая
       11

Плагин импорта воздушного потока

0 голосов
/ 18 апреля 2019

В настоящее время я пытаюсь отправить данные из Salesforce в BigQuery с помощью Airflow. Я новичок в воздушном потоке, и в настоящее время я перехожу по этой ссылке:

https://github.com/TheF1rstPancake/airflow-salesforce

Когда я пытаюсь импортировать плагин from airflow.operators import SalesforceToFileOperator,

Я получаю сообщение об ошибке ImportError: cannot import name 'SalesforceToFileOperator'

Как мне импортировать этот плагин в Airflow?

Текущая структура каталогов

DAGS 

  salesforce_bg.py

плагинов 

airflow-salesforce

      __init__.py
      hooks
      operators

Что я делаю не так?

1 Ответ

1 голос
/ 18 апреля 2019

Из официальной документации Airflow: здесь

Модули python в папке плагинов импортируются, а хуки, операторы, датчики, макросы, исполнители и веб-представления интегрируются в основные коллекции Airflow и становятся доступными для использования.

Итак, вам нужно всего лишь поместить salesforce_bg.py в папку /plugins вашего сервера Airflow.

...