在Airflow 2.0中开发自己的自定义运算符的最佳实践

from airflow.models import BaseOperator
from airflow.utils.decorators import apply_defaults

class MyCustomOperator(BaseOperator):
    @apply_defaults
    def __init__(self, my_param, *args, **kwargs):
        super(MyCustomOperator, self).__init__(*args, **kwargs)
        self.my_param = my_param

    def execute(self, context):
        # 自定义逻辑代码
        # 可以使用self.my_param来访问传入的参数
        # 可以使用context来访问任务上下文信息
        pass

    @staticmethod
    def get_parametrized(cls):
        return [
            {'name': 'my_param', 'type': 'str', 'default': 'default_value'}
        ]

my_task = MyCustomOperator(
    task_id='my_task',
    my_param='custom_value',
    dag=dag
)