DataWorks:Function Compute ノード

前提条件

開始する前に、以下の条件を満たしていることを確認してください。

• ワークスペースに [開発] または [ワークスペース管理者] ロールで追加された RAM ユーザー。 ワークスペース管理者ロールには、必要以上の権限が含まれています。 ワークスペース管理者ロールを割り当てる際には、十分ご注意ください。 詳細については、「ワークスペースにメンバーを追加してロールを割り当てる」をご参照ください。

• お使いのワークスペースに関連付けられたサーバーレス リソースグループです。詳細については、「サーバーレス リソースグループの使用」をご参照ください。

• DataWorks IDE で Function Compute ノードが作成済みであること。詳細については、「タスクノードの作成」をご参照ください。

サポートされるリージョン

Function Compute ノードは、以下のリージョンで作成されたワークスペースでのみ利用可能です：中国 (杭州)、中国 (上海)、中国 (北京)、中国 (張家口)、中国 (深セン)、中国 (香港)、シンガポール、イギリス (ロンドン)、米国 (シリコンバレー)、米国 (バージニア)、ドイツ (フランクフルト)、オーストラリア (シドニー)、インド (ムンバイ)。

制限事項

DataWorks はイベント関数のみ呼び出します。関数を定期的にスケジュール実行する場合は、HTTP 関数ではなくイベント関数を作成してください。詳細については、「関数タイプの選択」をご参照ください。

RAM ユーザーの権限

RAM ユーザーとして Function Compute ノードを開発する場合、RAM ユーザーに以下のポリシーをアタッチしてください。

その他のポリシー例については、「ポリシーおよびサンプルポリシー」および「サンプルポリシー」をご参照ください。

Function Compute ノードの構成

Function Compute ノードの構成タブで、以下のパラメーターを設定します。

import json
import logging

logger = logging.getLogger()

def handler(event, context):
    logger.info('event: %s', event)

    # JSON イベントペイロードを解析
    evt = json.loads(event)
    triggerName = evt["triggerName"]
    triggerTime = evt["triggerTime"]
    payload = evt["payload"]

    logger.info('triggerName: %s', triggerName)
    logger.info("triggerTime: %s", triggerTime)
    logger.info("payload: %s", payload)

    return 'Timer Payload: ' + payload

{
    "payload": "payload1",
    "triggerTime": "${bizdate}",
    "triggerName": "triggerName1"
}

スケジューリングの構成とデプロイメント

1. ノードを構成した後、スケジューリングプロパティを設定して、DataWorks が自動実行するタイミングを定義します。 詳細については、「スケジューリング構成」をご参照ください。

2. ノードを本番環境にデプロイします。詳細については、「ノードまたはワークフローのデプロイメント」をご参照ください。

3. デプロイメント後、[オペレーションセンター] > [自動トリガーノード] に移動して、デプロイされたノードを表示し、その実行を監視します。 詳細については、「オペレーションセンターの使用開始」をご参照ください。

トラブルシューティング

サービス一覧が表示されない：ノードの構成時に作成済みのサービス一覧が表示されない場合、以下の 2 つの原因を確認してください。

• ご利用のアカウントに支払い遅延がある。アカウントをチャージし、ノード構成ページをリフレッシュしてください。

• ご利用のアカウントに fc:ListServices 権限がありません。Alibaba Cloud アカウントの所有者に連絡し、fc:ListServices 権限を付与するか、AliyunFCFullAccess ポリシーをアタッチした後、ページをリフレッシュしてください。詳細については、「RAM ポリシーを使用した DataWorks サービスおよび DataWorks コンソール内のエンティティに対する権限管理」をご参照ください。