DataWorks：Pemicu HTTP node

Instal Alibaba Cloud SDK for Java. Untuk informasi lebih lanjut, lihat Mulai dengan Alibaba Cloud SDK V1.0 for Java.

Tentukan konfigurasi Project Object Model (POM) berikut untuk menggunakan DataWorks SDK for Java:

<dependency>
  <groupId>com.aliyun</groupId>
  <artifactId>aliyun-java-sdk-dataworks-public</artifactId>
  <version>3.4.2</version>
</dependency>

Gunakan kode contoh dan konfigurasikan parameter dalam kode.

Anda dapat pergi ke halaman debugging dari operasi RunTriggerNode dan melihat kode contoh lengkap di tab SDK Sample Code.

// File ini dihasilkan secara otomatis, jangan edit. Terima kasih.
package com.aliyun.sample;

import com.aliyun.tea.*;

public class Sample {

    /**
     *  :
     * <p>Gunakan pasangan AccessKey Anda untuk menginisialisasi klien.</p>
     * @return Client
     * 
     * @throws Exception
     */
    public static com.aliyun.dataworks_public20200518.Client createClient() throws Exception {
        // Jika kode proyek bocor, pasangan AccessKey mungkin bocor dan keamanan semua sumber daya dalam akun Anda mungkin terganggu. Kode contoh berikut hanya untuk referensi. 
        // Untuk keamanan yang lebih baik, kami sarankan Anda menggunakan kredensial akses sementara yang dikeluarkan oleh Security Token Service (STS). Untuk informasi lebih lanjut, lihat https://www.alibabacloud.com/help/en/sdk/developer-reference/v2-manage-access-credentials. 
        com.aliyun.teaopenapi.models.Config config = new com.aliyun.teaopenapi.models.Config()
                // Diperlukan. Pastikan bahwa variabel lingkungan ALIBABA_CLOUD_ACCESS_KEY_ID dikonfigurasi. 
                .setAccessKeyId(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_ID"))
                // Diperlukan. Pastikan bahwa variabel lingkungan ALIBABA_CLOUD_ACCESS_KEY_SECRET dikonfigurasi. 
                .setAccessKeySecret(System.getenv("ALIBABA_CLOUD_ACCESS_KEY_SECRET"));
        // Untuk informasi lebih lanjut tentang titik akhir, lihat https://api.aliyun.com/product/dataworks-public.
        config.endpoint = "dataworks.cn-shanghai.aliyuncs.com";
        return new com.aliyun.dataworks_public20200518.Client(config);
    }

    public static void main(String[] args_) throws Exception {
        java.util.List<String> args = java.util.Arrays.asList(args_);
        com.aliyun.dataworks_public20200518.Client client = Sample.createClient();
        com.aliyun.dataworks_public20200518.models.RunTriggerNodeRequest runTriggerNodeRequest = new com.aliyun.dataworks_public20200518.models.RunTriggerNodeRequest();
        com.aliyun.teautil.models.RuntimeOptions runtime = new com.aliyun.teautil.models.RuntimeOptions();
        try {
            // Tulis kode Anda sendiri untuk menampilkan respons dari operasi API jika perlu.
            client.runTriggerNodeWithOptions(runTriggerNodeRequest, runtime);
        } catch (TeaException error) {
            // Tangani pengecualian dengan hati-hati dalam skenario bisnis aktual dan jangan abaikan pengecualian dalam proyek Anda. Dalam contoh ini, pengecualian disediakan hanya untuk referensi. 
            // Pesan kesalahan.
            System.out.println(error.getMessage());
            // URL untuk pemecahan masalah.
            System.out.println(error.getData().get("Recommend"));
            com.aliyun.teautil.Common.assertAsString(error.message);
        } catch (Exception _error) {
            TeaException error = new TeaException(_error.getMessage(), _error);
            // Tangani pengecualian dengan hati-hati dalam skenario bisnis aktual dan jangan abaikan pengecualian dalam proyek Anda. Dalam contoh ini, pengecualian disediakan hanya untuk referensi. 
            // Pesan kesalahan.
            System.out.println(error.getMessage());
            // URL untuk pemecahan masalah.
            System.out.println(error.getData().get("Recommend"));
            com.aliyun.teautil.Common.assertAsString(error.message);
        }        
    }
}

Instal Alibaba Cloud SDK untuk Python. Untuk informasi lebih lanjut, lihat Integrasi dengan Alibaba Cloud SDK V1.0 untuk Python.

Jalankan perintah berikut untuk menginstal DataWorks SDK untuk Python:

pip install aliyun-python-sdk-dataworks-public==2.1.2

Gunakan kode contoh dan konfigurasikan parameter dalam kode tersebut.

Anda dapat pergi ke dan melihat kode contoh lengkap pada tab SDK Sample Code.

# -*- coding: utf-8 -*-
# File ini dihasilkan secara otomatis, jangan diedit. Terima kasih.
import os
import sys

from typing import List

from alibabacloud_dataworks_public20200518.client import Client as dataworks_public20200518Client
from alibabacloud_tea_openapi import models as open_api_models
from alibabacloud_dataworks_public20200518 import models as dataworks_public_20200518_models
from alibabacloud_tea_util import models as util_models
from alibabacloud_tea_util.client import Client as UtilClient


class Sample:
    def __init__(self):
        pass

    @staticmethod
    def create_client() -> dataworks_public20200518Client:
        """
        Gunakan ID AccessKey dan Rahasia AccessKey Anda untuk menginisialisasi klien.
        @return: Klien
        @throws Exception
        """
        # Jika kode proyek bocor, pasangan AccessKey mungkin bocor dan keamanan semua sumber daya dalam akun Anda mungkin terganggu. Contoh kode berikut hanya disediakan sebagai referensi. 
        # Untuk alasan keamanan, kami sarankan Anda menggunakan kredensial akses sementara yang disediakan oleh Security Token Service (STS). Untuk informasi lebih lanjut, kunjungi https://www.alibabacloud.com/help/en/sdk/developer-reference/v2-manage-php-access-credentials. 
        config = open_api_models.Config(
            # Diperlukan. Pastikan variabel lingkungan ALIBABA_CLOUD_ACCESS_KEY_ID dikonfigurasi. ,
            access_key_id=os.environ['ALIBABA_CLOUD_ACCESS_KEY_ID'],
            # Diperlukan. Pastikan variabel lingkungan ALIBABA_CLOUD_ACCESS_KEY_SECRET dikonfigurasi. ,
            access_key_secret=os.environ['ALIBABA_CLOUD_ACCESS_KEY_SECRET']
        )
        # Untuk informasi lebih lanjut tentang titik akhir, lihat https://api.aliyun.com/product/dataworks-public.
        config.endpoint = f'dataworks.cn-shanghai.aliyuncs.com'
        return dataworks_public20200518Client(config)

    @staticmethod
    def main(
        args: List[str],
    ) -> None:
        client = Sample.create_client()
        run_trigger_node_request = dataworks_public_20200518_models.RunTriggerNodeRequest()
        runtime = util_models.RuntimeOptions()
        try:
            # Cetak respons dari operasi API jika diperlukan.
            client.run_trigger_node_with_options(run_trigger_node_request, runtime)
        except Exception as error:
            # Tangani pengecualian dengan hati-hati dalam skenario bisnis aktual Anda dan jangan pernah abaikan pengecualian dalam proyek Anda. Dalam contoh ini, pesan kesalahan dicetak. 
            # Tampilkan pesan kesalahan.
            print(error.message)
            # Tampilkan URL untuk pemecahan masalah.
            print(error.data.get("Recommend"))
            UtilClient.assert_as_string(error.message)

    @staticmethod
    async def main_async(
        args: List[str],
    ) -> None:
        client = Sample.create_client()
        run_trigger_node_request = dataworks_public_20200518_models.RunTriggerNodeRequest()
        runtime = util_models.RuntimeOptions()
        try:
            # Cetak respons dari operasi API jika diperlukan.
            await client.run_trigger_node_with_options_async(run_trigger_node_request, runtime)
        except Exception as error:
            # Tangani pengecualian dengan hati-hati dalam skenario bisnis aktual Anda dan jangan pernah abaikan pengecualian dalam proyek Anda. Dalam contoh ini, pesan kesalahan dicetak. 
            # Tampilkan pesan kesalahan.
            print(error.message)
            # Tampilkan URL untuk pemecahan masalah.
            print(error.data.get("Recommend"))
            UtilClient.assert_as_string(error.message)


if __name__ == '__main__':
    Sample.main(sys.argv[1:])