本記事では、obshell-sdk-pythonを使用してタスクを操作する方法について説明します。
説明
from obshell import ClientSet, TaskExecuteFailedError
from obshell.auth import PasswordAuth
# クライアントインスタンスを作成します。ノードのアドレスは '10.10.10.1'、ポートは2886です。
# 所在クラスタのroot@sysパスワードは '****' です。
client = ClientSet("10.10.10.1", 2886, PasswordAuth("****"))
try:
# クラスタを初期化します。
client.v1.init_sync()
except TaskExecuteFailedError as e: # クラスタ初期化タスクの失敗をキャッチします。
client.v1.operate_dag_sync(e.dag-generic_id, "ROLLBACK") # そのタスクをロールバックします。
from obshell import ClientSet, TaskExecuteFailedError
from obshell.auth import PasswordAuth
# クライアントインスタンスを作成します。ノードのアドレスは '10.10.10.1'、ポートは2886です。
# クラスタのroot@sysパスワードは'****'です。
client = ClientSet("10.10.10.1", 2886, PasswordAuth("****"))
try:
# クラスタを初期化します。
client.v1.init_sync()
except TaskExecuteFailedError as e: # クラスタ初期化タスクの失敗をキャッチします。
client.v1.operate_dag(e.dag.generic_id, "ROLLBACK") # そのタスクをロールバックします。
関連ドキュメント
-
タスクの操作に関するAPIインターフェースの説明は、タスクの操作を参照してください。
obshell-sdk-goを使用したAPIメソッドのリクエストについては、タスクの操作を参照してください。