Data Management (DMS) は、DMS で管理されるリソースを安全に使用できるように、いくつかの Airflow オペレーターをカスタマイズしました。要件に応じてオペレーターを選択できます。
前提条件
手順
説明
詳細については、「ワークフロー開発」をご参照ください。
WORKSPACE または REPOS のコードページにアクセスします。
Python ファイルでコードを設定します。
オペレーター
説明
DMS で管理されているデータベースインスタンスに SQL を送信して実行し、結果を取得します。
DTS の機能を使用して、DMS で管理されているデータベースから Object Storage Service (OSS) にデータを同期します。
DMS で管理されている Notebook ファイル (.pynb) を実行します。
Data Lakehouse Edition AnalyticDB MySQL で管理されている特定のリソースグループに Spark SQL を送信します (タスクタイプは Interactive、DPI エンジンは Spark)。
Airflow インターフェイスで、または REST API を使用して、Python ファイルを実行します。