Python 如何使用Boto3停止AWS Glue Data Catalog中的工作流

在本文中，我们将看到如何停止AWS账户中的工作流。

示例

问题陈述： 使用Python中的 boto3 库停止工作流。

解决此问题的方法/算法

步骤1： 导入 boto3 和 botocore 异常以处理异常。
步骤2： workflow_name 和 run_id 是此函数中必需的参数。
步骤3： 使用 boto3 lib 创建AWS会话。确保在默认配置文件中提到了 region_name 。如果没有提到，则在创建会话时明确传递 region_name
步骤4： 为 glue 创建AWS客户端。
步骤5： 现在使用 stop_workflow_run 函数，并将参数 workflow_name 用作Name，将run_id用作RunId。
步骤6： 它返回响应元数据并停止工作流。
步骤7： 在停止工作流时处理通用异常。

示例代码

以下代码停止正在运行的工作流-

import boto3
from botocore.exceptions import ClientError

def stop_a_workflow(workflow_name, run_id)
   session = boto3.session.Session()
   glue_client = session.client('glue')
   try:
      response = glue_client.stop_workflow_run(Name=workflow_name, RunId= run_id)
      return response
   except ClientError as e:
      raise Exception("boto3 client error in stop_a_workflow: " + e.__str__())
   except Exception as e:
      raise Exception("Unexpected error in stop_a_workflow: " + e.__str__())
print(stop_a_workflow("test-daily"))

输出

{'RunId': 'wr_64e880240692fddd5e1b19aed587f856bc20a96f54bc', 'ResponseMetadata': {'RequestId': '782e953b-8ee3-4876-9b2c-cd35e147b513', 'HTTPStatusCode': 200, 'HTTPHeaders': {'date': 'Sun, 28 Mar 2021 08:11:02 GMT', 'content-type': 'application/x-amz-json-1.1', 'content-length': '79', 'connection': 'keep-alive', 'x-amzn-requestid': '782e953b-********************************13'}, 'RetryAttempts': 0}}