Realtime Compute for Apache Flink:Python SDK

この操作は、プロジェクトにデプロイされたジョブを開始します。以下のリクエストパラメーターが必要です。

• workspace：ワークスペース ID。例：adf9e5147a****。

• namespace：プロジェクト名。例：script****-default。

• deploymentId：ジョブのデプロイメント ID。この ID は、「デプロイ済みジョブのリストの取得」で説明されているように取得できます。例：3171d4d1-5952-4d02-b978-e762493b****。

• kind：開始オフセットのタイプ。有効な値：`NONE` (ステートレスで開始)、`LATEST_SAVEPOINT` (最新のスナップショットから開始)、`FROM_SAVEPOINT` (指定したスナップショットから開始)、`LATEST_STATE` (最新のステートから開始)。

# -*- coding: utf-8 -*-
import os
import sys

from typing import List

from alibabacloud_ververica20220718.client import Client as ververica20220718Client
from alibabacloud_tea_openapi import models as open_api_models
from alibabacloud_ververica20220718 import models as ververica_20220718_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() -> ververica20220718Client:
        """
        AccessKey ID と AccessKey Secret を使用してクライアントを初期化します。
        @return: Client
        @throws Exception
        """
        # プロジェクトコードが漏洩すると、AccessKey が漏洩し、アカウントのすべてのリソースのセキュリティが脅かされる可能性があります。STS などのより安全な方法を使用してください。以下のサンプルコードは参照用です。
        config = open_api_models.Config(
            # 必須。ALIBABA_CLOUD_ACCESS_KEY_ID 環境変数が設定されていることを確認してください。
            access_key_id=os.environ['ALIBABA_CLOUD_ACCESS_KEY_ID'],
            # 必須。ALIBABA_CLOUD_ACCESS_KEY_SECRET 環境変数が設定されていることを確認してください。
            access_key_secret=os.environ['ALIBABA_CLOUD_ACCESS_KEY_SECRET']
        )
        # 必要に応じてエンドポイントを変更してください。
        config.endpoint = f'ververica.cn-hangzhou.aliyuncs.com'
        return ververica20220718Client(config)

    @staticmethod
    def main(
        args: List[str],
    ) -> None:
        client = Sample.create_client()
        start_job_with_params_headers = ververica_20220718_models.StartJobWithParamsHeaders(
            workspace='workspace'
        )
        job_start_parameters_deployment_restore_strategy = ververica_20220718_models.DeploymentRestoreStrategy(
            kind='NONE'
        )
        job_start_parameters = ververica_20220718_models.JobStartParameters(
            deployment_id='deploymentId',
            restore_strategy=job_start_parameters_deployment_restore_strategy
        )
        start_job_with_params_request = ververica_20220718_models.StartJobWithParamsRequest(
            body=job_start_parameters
        )
        runtime = util_models.RuntimeOptions()
        try:
            # コードをコピーして実行する場合は、API の戻り値を自分で表示してください。
            client.start_job_with_params_with_options('namespace', start_job_with_params_request, start_job_with_params_headers, runtime)
        except Exception as error:
            # これはデモンストレーション用です。例外の処理には注意してください。プロジェクトで例外を無視しないでください。
            # エラーメッセージ
            print(error.message)
            # トラブルシューティング URL
            print(error.data.get("Recommend"))
            UtilClient.assert_as_string(error.message)

    @staticmethod
    async def main_async(
        args: List[str],
    ) -> None:
        client = Sample.create_client()
        start_job_with_params_headers = ververica_20220718_models.StartJobWithParamsHeaders(
            workspace='workspace'
        )
        job_start_parameters_deployment_restore_strategy = ververica_20220718_models.DeploymentRestoreStrategy(
            # ジョブ開始ポリシー
            kind='NONE'
        )
        job_start_parameters = ververica_20220718_models.JobStartParameters(
            deployment_id='deploymentId',
            restore_strategy=job_start_parameters_deployment_restore_strategy
        )
        start_job_with_params_request = ververica_20220718_models.StartJobWithParamsRequest(
            body=job_start_parameters
        )
        runtime = util_models.RuntimeOptions()
        try:
            # コードをコピーして実行する場合は、API の戻り値を自分で表示してください。
            await client.start_job_with_params_with_options_async('namespace', start_job_with_params_request, start_job_with_params_headers, runtime)
        except Exception as error:
            # これはデモンストレーション用です。例外の処理には注意してください。プロジェクトで例外を無視しないでください。
            # エラーメッセージ
            print(error.message)
            # トラブルシューティング URL
            print(error.data.get("Recommend"))
            UtilClient.assert_as_string(error.message)


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

デプロイメント内のすべてのジョブインスタンスに関する情報を取得できます。必須のリクエストパラメーターは以下の通りです。

• workspace：ワークスペース ID。例：adf9e5147a****。

• namespace：プロジェクト名。例：script****-default。

• deploymentId：ジョブのデプロイメント ID。この ID は、「デプロイ済みジョブのリストの取得」で説明されているように取得できます。例：3171d4d1-5952-4d02-b978-e762493b****。

# -*- coding: utf-8 -*-
import os
import sys

from typing import List

from alibabacloud_ververica20220718.client import Client as ververica20220718Client
from alibabacloud_tea_openapi import models as open_api_models
from alibabacloud_ververica20220718 import models as ververica_20220718_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() -> ververica20220718Client:
        """
        AccessKey ID と AccessKey Secret を使用してクライアントを初期化します。
        @return: Client
        @throws Exception
        """
        # プロジェクトコードが漏洩すると、AccessKey が漏洩し、アカウントのすべてのリソースのセキュリティが脅かされる可能性があります。STS などのより安全な方法を使用してください。以下のサンプルコードは参照用です。
        config = open_api_models.Config(
            # 必須。ALIBABA_CLOUD_ACCESS_KEY_ID 環境変数が設定されていることを確認してください。
            access_key_id=os.environ['ALIBABA_CLOUD_ACCESS_KEY_ID'],
            # 必須。ALIBABA_CLOUD_ACCESS_KEY_SECRET 環境変数が設定されていることを確認してください。
            access_key_secret=os.environ['ALIBABA_CLOUD_ACCESS_KEY_SECRET']
        )
        # 必要に応じてエンドポイントを変更してください。
        config.endpoint = f'ververica.cn-hangzhou.aliyuncs.com'
        return ververica20220718Client(config)

    @staticmethod
    def main(
        args: List[str],
    ) -> None:
        client = Sample.create_client()
        list_jobs_headers = ververica_20220718_models.ListJobsHeaders(
            workspace='workspace'
        )
        list_jobs_request = ververica_20220718_models.ListJobsRequest(
            deployment_id='deploymentId'
        )
        runtime = util_models.RuntimeOptions()
        try:
            # API を呼び出し、戻り値を表示します。
            request=client.list_jobs_with_options('namespace', list_jobs_request, list_jobs_headers, runtime)
            print(request)
        except Exception as error:
            # これはデモンストレーション用です。例外の処理には注意してください。プロジェクトで例外を無視しないでください。
            # エラーメッセージ
            print(error.message)
            # トラブルシューティング URL
            print(error.data.get("Recommend"))
            UtilClient.assert_as_string(error.message)

    @staticmethod
    async def main_async(
        args: List[str],
    ) -> None:
        client = Sample.create_client()
        list_jobs_headers = ververica_20220718_models.ListJobsHeaders(
            workspace='workspace'
        )
        list_jobs_request = ververica_20220718_models.ListJobsRequest(
            deployment_id='deploymentId'
        )
        runtime = util_models.RuntimeOptions()
        try:
            # コードをコピーして実行する場合は、API の戻り値を自分で表示してください。
            await client.list_jobs_with_options_async('namespace', list_jobs_request, list_jobs_headers, runtime)
        except Exception as error:
            # これはデモンストレーション用です。例外の処理には注意してください。プロジェクトで例外を無視しないでください。
            # エラーメッセージ
            print(error.message)
            # トラブルシューティング URL
            print(error.data.get("Recommend"))
            UtilClient.assert_as_string(error.message)


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

ジョブインスタンスを停止できます。必須のリクエストパラメーターは以下の通りです。。

• workspace：ワークスペース ID。例：adf9e5147a****。

• namespace：プロジェクト名。例：script****-default。

• jobId：ジョブインスタンス ID。この ID は、「ジョブインスタンスのリストの取得」で説明されているように取得できます。例：3171d4d1-5952-4d02-b978-e762493b****。

• stopStrategy：ジョブを停止するために使用されるポリシー。有効な値：`NONE` (即時停止)、`STOP_WITH_SAVEPOINT` (スナップショットを作成してから停止)、`STOP_WITH_DRAIN` (ドレインして停止)。

# -*- coding: utf-8 -*-
import os
import sys

from typing import List

from alibabacloud_ververica20220718.client import Client as ververica20220718Client
from alibabacloud_tea_openapi import models as open_api_models
from alibabacloud_ververica20220718 import models as ververica_20220718_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() -> ververica20220718Client:
        """
        AccessKey ID と AccessKey Secret を使用してクライアントを初期化します。
        @return: Client
        @throws Exception
        """
        # プロジェクトコードが漏洩すると、AccessKey が漏洩し、アカウントのすべてのリソースのセキュリティが脅かされる可能性があります。STS などのより安全な方法を使用してください。以下のサンプルコードは参照用です。
        config = open_api_models.Config(
            # 必須。ALIBABA_CLOUD_ACCESS_KEY_ID 環境変数が設定されていることを確認してください。
            access_key_id=os.environ['ALIBABA_CLOUD_ACCESS_KEY_ID'],
            # 必須。ALIBABA_CLOUD_ACCESS_KEY_SECRET 環境変数が設定されていることを確認してください。
            access_key_secret=os.environ['ALIBABA_CLOUD_ACCESS_KEY_SECRET']
        )
        # 必要に応じてエンドポイントを変更してください。
        config.endpoint = f'ververica.cn-hangzhou.aliyuncs.com'
        return ververica20220718Client(config)

    @staticmethod
    def main(
        args: List[str],
    ) -> None:
        client = Sample.create_client()
        stop_job_headers = ververica_20220718_models.StopJobHeaders(
            workspace='workspace'
        )
        stop_job_request_body = ververica_20220718_models.StopJobRequestBody(
            # ジョブ停止ポリシー
            stop_strategy='stopStrategy'
        )
        stop_job_request = ververica_20220718_models.StopJobRequest(
            body=stop_job_request_body
        )
        runtime = util_models.RuntimeOptions()
        try:
            # コードをコピーして実行する場合は、API の戻り値を自分で表示してください。
            client.stop_job_with_options('namespace', 'jobId', stop_job_request, stop_job_headers, runtime)
        except Exception as error:
            # これはデモンストレーション用です。例外の処理には注意してください。プロジェクトで例外を無視しないでください。
            # エラーメッセージ
            print(error.message)
            # トラブルシューティング URL
            print(error.data.get("Recommend"))
            UtilClient.assert_as_string(error.message)

    @staticmethod
    async def main_async(
        args: List[str],
    ) -> None:
        client = Sample.create_client()
        stop_job_headers = ververica_20220718_models.StopJobHeaders(
            workspace='workspace'
        )
        stop_job_request_body = ververica_20220718_models.StopJobRequestBody(
            stop_strategy='stopStrategy'
        )
        stop_job_request = ververica_20220718_models.StopJobRequest(
            body=stop_job_request_body
        )
        runtime = util_models.RuntimeOptions()
        try:
            # コードをコピーして実行する場合は、API の戻り値を自分で表示してください。
            await client.stop_job_with_options_async('namespace', 'jobId', stop_job_request, stop_job_headers, runtime)
        except Exception as error:
            # これはデモンストレーション用です。例外の処理には注意してください。プロジェクトで例外を無視しないでください。
            # エラーメッセージ
            print(error.message)
            # トラブルシューティング URL
            print(error.data.get("Recommend"))
            UtilClient.assert_as_string(error.message)


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