极客教程如何使用Boto3分页浏览AWS Glue中存在的所有数据库
在本文中，我们将看到如何分页浏览AWS Glue中存在的所有数据库。
更多Python相关文章，请阅读：Python 教程
示例
问题陈述： 在Python中使用 boto3 库，对创建在您的账户中的AWS Glue数据目录中的所有数据库进行分页处理。
解决问题的方法/算法
- 步骤1: 导入 boto3 和 botocore 异常以处理异常。
-
步骤2: max_items 、 page_size 和 starting_token 是此函数的参数。
- max_items 表示要返回的记录总数。 如果可用记录数> max_items ，则响应中会提供NextToken以恢复分页。
-
page_size 表示每个页面的大小。
-
starting_token 有助于分页，并使用先前响应中的 NextToken，
-
步骤3: 使用 boto3库 创建AWS会话。 确保在默认配置文件中提到了 region_name 。 如果没有提到，则在创建会话时明确传递 region_name 。
-
步骤4: 创建一个glue的AWS客户端。
-
步骤5: 使用 get_databases 创建包含所有crawler详细信息的 paginator 对象。
-
步骤6: 调用 paginate 函数，并将 max_items 、 page_size 和 starting_token 作为PaginationConfig传递。
-
步骤7: 它基于 max_size 和 page_size 返回记录数。
-
步骤8: 如果在分页时出现错误，处理通用异常。
示例代码
使用以下代码分页浏览用户账户中创建的所有crawler−
import boto3
from botocore.exceptions import ClientError
def paginate_through_databases(max_items=None:int,page_size=None:int, starting_token=None:string):
session = boto3.session.Session()
glue_client = session.client('glue')
try:
paginator = glue_client.get_paginator('get_databases')
response = paginator.paginate(PaginationConfig={
'MaxItems':max_items,
'PageSize':page_size,
'StartingToken':starting_token}
)
return response
except ClientError as e:
raise Exception("boto3 client error in paginate_through_databases: " + e.__str__())
except Exception as e:
raise Exception("Unexpected error in paginate_through_databases: " + e.__str__())
a = paginate_through_databases(2,5)
print(*a)
输出
{'DatabaseList': [
{'Name': 'aurora_glue_catalog', 'CreateTime': datetime.datetime(2020, 11, 18, 14, 24, 46, tzinfo=tzlocal())},
{'Name': 'custdb', 'CreateTime': datetime.datetime(2020, 8, 31, 20, 30, 9, tzinfo=tzlocal())}],
'NextToken': 'eyJsYXN0RXZhbHVhdGVkS2V5Ijp7IkhBU0hfS0VZIjp7InMiOiJuLjc4MjI1ODQ4NTg0MSJ9LCJSQU5HRV9LRVkiOnsicyI6ImRldjEtZnJlYV9lZGxfZ2x1ZV9kYXRhYmFzZSJ9fSwiZXhwaXJhdGlvbiI6eyJzZWNvbmRzIjoxNjE3NDUwNDQxLCJuYW5vcyI6ODcwMDAwMDB9LCJzaGFyZWRDb250ZXh0IjpmYWxzZSwidGFnQ29udGV4dCI6ZmFsc2V9',
'ResponseMetadata': {'RequestId': '3e1c4f54-d573-4ba9-9948-832273ecca02', 'HTTPStatusCode': 200, 'HTTPHeaders': {'date': 'Fri, 02 Apr 2021 11:47:21 GMT', 'content-type': 'application/x-amz-json-1.1', 'content-length': '1617', 'connection': 'keep-alive', 'x-amzn-requestid': '3e1c4f54-d573-4ba9-9948-832273ecca02'}, 'RetryAttempts': 0}}