如何使用 Boto3 获取迁移操作的状态?


问题陈述 − 使用 Python 中的 boto3 库获取迁移操作的状态。

示例 − 获取账户中迁移操作的状态。

解决此问题的方法/算法

步骤 1 − 导入 boto3 和 botocore 异常以处理异常。

步骤 2 − 传递参数 catalog_id,需要检查其迁移状态。但是,这是一个可选参数。如果未提供,则默认情况下它会检查登录用户的账户,迁移是否正在进行或已完成。catalog_id 只是用户账户 ID。

步骤 3 − 使用 boto3 库创建 AWS 会话。确保在默认配置文件中提到了 region_name。如果未提及,则在创建会话时显式传递 region_name。

步骤 4 − 为 Glue 创建 AWS 客户端。

步骤 5 − 调用 get_catalog_import_status 并将 catalog_id 作为 CatalogId 参数传递。

步骤 6 − 它将获取正在进行的迁移操作的详细信息。否则,它将获取上次迁移的详细信息。

步骤 7 − 如果在检查作业时出现任何错误,则处理通用异常。

示例

使用以下代码获取迁移操作的状态 -

import boto3
from botocore.exceptions import ClientError

def status_of_migration(catalog_id = None):
   session = boto3.session.Session()
   glue_client = session.client('glue')
   try:
      response = glue_client.get_catalog_import_status(CatalogId = catalog_id)
      return response
   except ClientError as e:
      raise Exception( "boto3 client error in status_of_migration: " + e.__str__())
   except Exception as e:
      raise Exception("Unexpected error in status_of_migration: " + e.__str__())

print(status_of_migration())

输出

{'ImportStatus': {'ImportCompleted': True, 'ImportTime':
datetime.datetime(2017, 11, 17, 1, 32, 44, tzinfo=tzlocal()),
'ImportedBy': 'StatusSetByDefault'}, 'ResponseMetadata': {'RequestId':
'7c33d6f9-……………..-3b202961e3e7', 'HTTPStatusCode': 200, 'HTTPHeaders':
{'date': 'Sun, 21 Feb 2021 05:40:06 GMT', 'content-type':
'application/x-amz-json-1.1', 'content-length': '102', 'connection':
'keep-alive', 'x-amzn-requestid': '7c33d6f9-…….…………-3b202961e3e7'},
'RetryAttempts': 0}}

更新于: 2021年3月22日

130 次查看

开启您的 职业生涯

通过完成课程获得认证

开始学习
广告

© . All rights reserved.