ในบทความนี้ เราจะมาดูวิธีอัปเดตรายละเอียดของเวิร์กโฟลว์ใน AWS Glue Catalog
ตัวอย่าง
คำชี้แจงปัญหา: ใช้ boto3 ไลบรารีใน Python เพื่ออัปเดตรายละเอียดของเวิร์กโฟลว์ที่สร้างขึ้นในบัญชีของคุณ
แนวทาง/อัลกอริทึมในการแก้ปัญหานี้
-
ขั้นตอนที่ 1: นำเข้า boto3 และ botcore ข้อยกเว้นในการจัดการข้อยกเว้น
-
ขั้นตอนที่ 2: ชื่อเวิร์กโฟลว์ เป็นพารามิเตอร์ที่จำเป็นสำหรับฟังก์ชันนี้ คำอธิบาย และ deault_run_properties เป็นพารามิเตอร์ทางเลือก โดยจะอัปเดตรายละเอียดของเวิร์กโฟลว์ที่กำหนด
-
ขั้นตอนที่ 3: สร้างเซสชัน AWS โดยใช้ boto3 lib . ตรวจสอบให้แน่ใจว่า region_name ถูกกล่าวถึงในโปรไฟล์เริ่มต้น หากไม่กล่าวถึง ให้ส่ง region_name . อย่างชัดแจ้ง ขณะสร้างเซสชัน
-
ขั้นตอนที่ 4: สร้างไคลเอ็นต์ AWS สำหรับ กาว .
-
ขั้นตอนที่ 5: โทร update_workflow และส่งผ่าน workflow_name เป็นพารามิเตอร์ชื่อและคำอธิบายเป็นคำอธิบายและ default_run_properties เป็น DefaultRunProperties
-
ขั้นตอนที่ 6: ส่งคืนข้อมูลเมตาของเวิร์กโฟลว์ที่กำหนด
-
ขั้นตอนที่ 7: จัดการกับข้อยกเว้นทั่วไปหากมีข้อผิดพลาดขณะตรวจสอบงาน
โค้ดตัวอย่าง
รหัสต่อไปนี้จะอัปเดตรายละเอียดของเวิร์กโฟลว์ที่สร้างขึ้นในบัญชีผู้ใช้ -
import boto3
from botocore.exceptions import ClientError
def update_resource_detail_of_workflow(workflow_name, description=None, default_run_properties=None:dict):
session = boto3.session.Session()
glue_client = session.client('glue')
try:
response = glue_client.update_workflow(Name=workflow_name, Description = description, DefaultRunProperties = default_run_properties)
return response
except ClientError as e:
raise Exception("boto3 client error in update_resource_detail_of_workflow: " + e.__str__())
except Exception as e:
raise Exception("Unexpected error in update_resource_detail_of_workflow: " + e.__str__())
a = update_resource_detail_of_workflow('dev-aiml-naviga-ods-load', 'test')
print(a) ผลลัพธ์
{'Name': 'dev-aiml-naviga-ods-load', 'ResponseMetadata': {'RequestId': 'b328d064-24ab-48c4-b058-852387a3d474', 'HTTPStatusCode': 200, 'HTTPHeaders': {'date': 'Sat, 27 Feb 2021 13:57:37 GMT', 'content-type': 'application/x-amz-json-1.1', 'content-length': '2655', 'connection': 'keep-alive', 'x-amzn-requestid': 'b328d064-24ab-48c4-b058-852387a3d474'}, 'RetryAttempts': 0}} 