Computer >> คอมพิวเตอร์ >  >> การเขียนโปรแกรม >> Python

จะใช้ Boto3 เพื่อรับสถานะของการดำเนินการโยกย้ายได้อย่างไร?


คำชี้แจงปัญหา − ใช้ไลบรารี boto3 ใน Python เพื่อรับสถานะของการดำเนินการย้ายข้อมูล

ตัวอย่าง - รับสถานะการดำเนินการย้ายข้อมูลในบัญชี

แนวทาง/อัลกอริทึมในการแก้ปัญหานี้

ขั้นตอนที่ 1 - นำเข้าข้อยกเว้น boto3 และ botocore เพื่อจัดการกับข้อยกเว้น

ขั้นตอนที่ 2 − ผ่านพารามิเตอร์ catalog_id ที่ต้องการตรวจสอบสถานะการย้ายข้อมูล อย่างไรก็ตาม นี่เป็นพารามิเตอร์ทางเลือก หากไม่มีให้ โดยค่าเริ่มต้น ระบบจะตรวจสอบบัญชีผู้ใช้ที่เข้าสู่ระบบว่าการย้ายข้อมูลอยู่ในระหว่างดำเนินการหรือเสร็จสิ้น Catalog_id ไม่ใช่อะไรอื่นนอกจาก ID บัญชีผู้ใช้

ขั้นตอนที่ 3 − สร้างเซสชัน AWS โดยใช้ไลบรารี boto3 ตรวจสอบให้แน่ใจว่ามีการกล่าวถึง region_name ในโปรไฟล์เริ่มต้น หากไม่มีการระบุ ให้ส่ง region_name อย่างชัดเจนขณะสร้างเซสชัน

ขั้นตอนที่ 4 − สร้างไคลเอนต์ 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}}