Amazon AirFlow 1.10.12：没有名为“操作员”的模块

Question

我正在为 Amazon AirFlow 1.10.12 创建一个插件和 dag 结构。我是按照文档做的：

dags:
 - aws_from_redshift_to_s3.py
plugins:
 - __init__.py
 - from_redshift_to_s3_plugin.py
 - operators:
  -- __init__.py
  -- aws_from_redshift_to_s3_operator.py

aws_from_redshift_to_s3_operator.py：

from airflow.hooks.postgres_hook import PostgresHook
from airflow.models import BaseOperator
from airflow.utils.decorators import apply_defaults
from airflow.contrib.hooks.aws_hook import AwsHook


class FromRedshiftToS3TransferOperator(BaseOperator):
pass

from_redshift_to_s3_plugin.py：

from airflow.plugins_manager import AirflowPlugin
from operators.aws_from_redshift_to_s3_operator import FromRedshiftToS3TransferOperator


class FromRedShiftToS3Plugin(AirflowPlugin):
    name = 'from_redshift_to_s3_plugin'
    operators = [FromRedshiftToS3TransferOperator]

В самом ДАГе подключаю так:

从 operator.from_redshift_to_s3_plugin 导入 FromRedshiftToS3TransferOperator При попытке активировать ДАГ в Amazon AirFlow 1.10.12 получаю ошибку：没有名为“运营商”的模块

Answer 1

https://airflow.apache.org/docs/apache-airflow/1.10.12/howto/custom-operator.html

如本文档中所述，您不再需要从运算符导入。而是尝试像这样导入，

from aws_from_redshift_to_s3_operator import FromRedshiftToS3TransferOperator