导入Airflow插件

Question

我目前正在尝试使用Airflow将数据从Salesforce推送到BigQuery。我是气流新手，目前我正在关注此链接：

当我尝试导入插件from airflow.operators import SalesforceToFileOperator时，

我收到说明ImportError: cannot import name 'SalesforceToFileOperator'的错误消息

如何在Airflow上导入此插件？

当前目录结构

TIME

  salesforce_bg.py

插件

airflow-salesforce

      __init__.py
      hooks
      operators

我究竟做错了什么？

Answer 1

从官方Airflow文档：here

插件文件夹中的python模块将被导入，钩子，操作符，传感器，宏，执行器和Web视图将集成到Airflow的主要集合中，并可供使用。

因此，您只需将salesforce_bg.py放入Airflow服务器的/plugins文件夹中。