Google Cloud Dataprocを使用してsparkJobを実行しています。 クラスタに対応するすべてのジョブとその状態のリストを取得する必要があります。Dataprocクライアント:googleapiclient:クラスタ内のすべてのジョブ(runnng、stoppedなど)のリストを取得するメソッド
私がJOB_IDを知っていれば私は
res = dpclient.dataproc.projects().regions().jobs().get(
projectId=project,
region=region,
jobId="ab4f5d05-e890-4ff5-96ef-017df2b5c0bc").execute()
の下に、ジョブのステータスを取得することができます。しかし、私がJOB_IDを知らないし、すべてのジョブ
の状況を知りたい場合はどのようなclusterName = 'cluster-1'
res = dpclient.dataproc.projects().regions().jobs().list(
projectId=project,
region=region,
clusterName=clusterName).execute()
しかし、これが唯一現在も存在してクラスターによってリストをサポートしていることに注意してください;:クラスタ内のジョブを一覧表示するには