数据结构
网络
关系数据库管理系统
操作系统
Java
MS Excel
iOS
HTML
CSS
Android
Python
C 编程
C++
C#
MongoDB
MySQL
Javascript
PHP
物理学
化学
生物学
数学
英语
经济学
心理学
社会学
时尚研究
法律研究如何使用 Boto3 一次获取所有 Glue 作业的定义？
问题陈述 − 使用 Python 中的 boto3 库获取用户 AWS Glue 数据目录中所有 Glue 作业的定义。
示例 − 获取 AWS Glue 数据目录中所有 Glue 作业的定义。
解决此问题的方法/算法
步骤 1 − 导入 boto3 和 botocore 异常以处理异常。
步骤 2 − 此函数不需要参数。它将获取用户帐户所有已列出作业的定义。
步骤 3 − 使用 boto3 库创建 AWS 会话。确保在默认配置文件中提到了region_name。如果未提及，则在创建会话时显式传递region_name。
步骤 4 − 为 Glue 创建 AWS 客户端。
步骤 5 − 现在使用 get_jobs 函数获取用户帐户中列出的所有作业的定义。请注意，list_jobs 和get_jobs 之间存在差异。List_jobs 仅获取 AWS Glue 数据目录中存在的 Glue 作业的名称，而get_jobs 则检索每个作业的定义。
步骤 6 − 它返回每个作业的定义。
步骤 7 − 如果在检查作业时出现问题，则处理通用异常。
示例
使用以下代码获取用户帐户中列出的每个作业的定义：
import boto3
from botocore.exceptions import ClientError
def get_definition_of_glue_jobs():
session = boto3.session.Session()
glue_client = session.client('glue')
try:
response = glue_client.get_jobs()
return response
except ClientError as e:
raise Exception("boto3 client error in get_definition_of_glue_jobs: " + e.__str__())
except Exception as e:
raise Exception("Unexpected error in get_definition_of_glue_jobs: " + e.__str__())
print(get_definition_of_glue_jobs())输出
{'Jobs': [
{'Name': '01_PythonShellTest1', 'Role': 'arn:aws:iam::********:role/devedl-glue-role', 'CreatedOn': datetime.datetime(2021, 1, 6, 19, 59, 19,
387000, tzinfo=tzlocal()), 'LastModifiedOn': datetime.datetime(2021, 2, 9,
21, 47, 31, 614000, tzinfo=tzlocal()), 'ExecutionProperty':
{'MaxConcurrentRuns': 1}, 'Command': {'Name': 'pythonshell',
'ScriptLocation': 's3://ivz-dev-ds-staging-
/01_pythonShellTest/test1/01_PythonShellTest1.py', 'PythonVersion': '3'},
'DefaultArguments': {'--job-bookmark-option': 'job-bookmark-disable', '--
job-language': 'python'}, 'MaxRetries': 0, 'AllocatedCapacity': 0,
'Timeout': 2880, 'MaxCapacity': 0.0625, 'GlueVersion': '1.0'},
{'Name': '01_pythonSHELL_14012021', 'Role':
'arn:aws:iam::*********:role/dev-edl-glue-role', 'CreatedOn':
datetime.datetime(2021, 1, 14, 20, 22, 40, 965000, tzinfo=tzlocal()),
'LastModifiedOn': datetime.datetime(2021, 1, 14, 20, 22, 40, 965000,
tzinfo=tzlocal()), 'ExecutionProperty': {'MaxConcurrentRuns': 1},
'Command': {'Name': 'pythonshell', 'ScriptLocation': 's3://ivz-dev-dsstaging-work/ /test_14012021/01_pythonSHELL_14012021_123.py',
'PythonVersion': '3'}, 'DefaultArguments': {'--job-bookmark-option': 'jobbookmark-disable'}, 'MaxRetries': 0, 'AllocatedCapacity': 0, 'Timeout':
2880, 'MaxCapacity': 0.0625, 'GlueVersion': '1.0'},
{'Name': 'GlueConnectionTest', 'Role': 'arn:aws:iam::*********:role/devedl-qa-automation-glue-role', 'CreatedOn': datetime.datetime(2020, 3, 6,
16, 27, 3, 862000, tzinfo=tzlocal()), 'LastModifiedOn':
datetime.datetime(2020, 3, 6, 16, 49, 19, 942000, tzinfo=tzlocal()),
'ExecutionProperty': {'MaxConcurrentRuns': 1}, 'Command': {'Name':
'pythonshell', 'ScriptLocation': 's3://glue-job-connection-testbucket/test.py', 'PythonVersion': '3'}, 'DefaultArguments': {'--jobbookmark-option': 'job-bookmark-disable', '--job-language': 'python'},
'Connections': {'Connections': ['dev-edl-redshift-glue-connection', 'devedl-rds-glue-connection']}, 'MaxRetries': 0, 'AllocatedCapacity': 0,
'Timeout': 2880, 'MaxCapacity': 0.0625, 'GlueVersion': '1.0'}] 'NextToken':
'eyJleHBpcmF0aW9uIjp7InNlY29uZHMiOjE2MTQ2NjI2MTAsIm5hbm9zIjo2MjEwMDAwMDB9LC
JsYXN0RXZhbHVhdGVkS2V5Ijp7ImpvYk5hbWUiOnsicyI6InRpY2stZGF0YS10ZXN0In0sImFjY
291bnRJZCI6eyJzIjoiNzgyMjU4NDg1ODQxIn0sImpvYklkIjp7InMiOiJqXzhmZDc2MzhkYTcy
MGQ5Yzk1YTg4MTlkOTgxNTE5MDdjM2JmYWI3ZGYxNGUwNGExZGM0ZTIzZjViYjczM2M2ZTYifX1
9', 'ResponseMetadata': {'RequestId': '287ad828-
**************************af', 'HTTPStatusCode': 200, 'HTTPHeaders':
{'date': 'Mon, 01 Mar 2021 05:23:30 GMT', 'content-type': 'application/xamz-json-1.1', 'content-length': '8258', 'connection': 'keep-alive', 'xamzn-requestid': '287ad828-*****************af'}, 'RetryAttempts': 0}}
更新于： 2021年3月23日
460 次浏览
广告