Airflow DMS Operator

前提条件

• 已创建Airflow实例。

• 已新增关联账号。

• 已创建代码仓库。

操作步骤

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

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

   Operator	说明
   DMSSqlOperator	将SQL提交到DMS管理的数据库实例中执行，并获取结果。
   DTSLakeInjectionOperator	借助DTS的能力，将DMS管理的数据库中的数据同步到对象存储OSS上。
   DMSNotebookOperator	执行一个DMS管理的Notebook文件（.pynb）。
   DMSAnalyticDBSparkSqlOperator	将Spark SQL提交到湖仓版AnalyticDB MySQL管理的特定资源组上（任务类型为Interactive、引擎为Spark）。

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