Airflow DMS Operator

前提条件

• 已创建Airflow实例。

• 已新增关联账号。

• 已创建代码仓库。

操作步骤

1. 已进入WORKSPACE或REPOS配置代码页面。

2. 在Python文件中配置代码。

   Operator	说明
   DMSSqlOperator	将SQL提交到DMS管理的数据库实例中执行，并获取结果。
   DTSLakeInjectionOperator	借助DTS的能力，将DMS管理的数据库中的数据同步到对象存储OSS上。
   DMSNotebookOperator	执行一个DMS管理的Notebook文件（.pynb）。
   DMSAnalyticDBSparkOperator	将Spark SQL提交到湖仓版AnalyticDB MySQL管理的特定资源组上（任务类型为Interactive、引擎为Spark）。
   DMSLockFreeSqlOperator	通过DMS分块DML服务执行无锁大批量DML操作，适用于大表UPDATE或DELETE场景。
   DMSLindormSparkOperator	在Lindorm Spark引擎上执行SQL或JAR任务。

3. 在Airflow界面或使用REST API，运行Python文件。

通用特性

以下特性适用于所有DMS Airflow Operator。