如何使用 Boto3 遍歷 AWS Glue 中的所有觸發器
問題陳述:使用 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:建立一個 paginator 物件,其中包含使用 get_triggers 獲取的所有觸發器的詳細資訊。
步驟 5:呼叫 paginate 函式並將 max_items、page_size 和 starting_token 作為 PaginationConfig 引數傳遞。
步驟 6:它根據 max_size 和 page_size 返回記錄數。
步驟 7:如果在分頁過程中出現問題,則處理通用異常。
示例程式碼
使用以下程式碼遍歷使用者帳戶中建立的所有觸發器:
import boto3
from botocore.exceptions import ClientError
def paginate_through_triggers(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_triggers')
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_triggers: " + e.__str__())
except Exception as e:
raise Exception("Unexpected error in paginate_through_triggers: " + e.__str__())
page_itr = paginate_through_tables("test_db",2,5)
for page in page_itr:
print(page['Triggers']輸出
[{'Name': 'file-passed', 'WorkflowName': 'data-tx', 'Type': 'CONDITIONAL', 'State': 'ACTIVATED', 'Actions': [{'JobName': 'data-event'}], 'Predicate': {'Logical': 'ANY', 'Conditions': [{'LogicalOperator': 'EQUALS', 'JobName': 'data-worker', 'State': 'SUCCEEDED'}]}},
{'Name': 'file-passed-to-acc', 'WorkflowName': 'tick-data', 'Type': 'CONDITIONAL', 'State': 'ACTIVATED', 'Actions': [{'JobName': 'tick-data'}], 'Predicate': {'Logical': 'ANY', 'Conditions': [{'LogicalOperator': 'EQUALS', 'JobName': 'tick-data', 'State': 'SUCCEEDED'}]}}
廣告
資料結構
網路
關係資料庫管理系統 (RDBMS)
作業系統
Java
iOS
HTML
CSS
Android
Python
C 語言程式設計
C++
C#
MongoDB
MySQL
Javascript
PHP