จะใช้ Boto3 เพื่อตรวจสอบสถานะของงานกาวที่กำลังทำงานได้อย่างไร?

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

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

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

ขั้นตอนที่ 2 − ชื่องาน เป็นพารามิเตอร์บังคับ ในขณะที่อาร์กิวเมนต์ เป็นพารามิเตอร์ทางเลือกในฟังก์ชัน งานน้อยใช้อาร์กิวเมนต์ในการทำงาน ในกรณีนั้น อาร์กิวเมนต์สามารถส่งผ่านเป็นคำสั่งได้

ตัวอย่างเช่น อาร์กิวเมนต์ ={'arguments1' ='value1', 'arguments2' ='value2'}

ถ้างานไม่มีข้อโต้แย้ง ก็ส่งต่อ job_name ไปเลย

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

ขั้นตอนที่ 4 − สร้างไคลเอนต์ AWS สำหรับกาว

ขั้นตอนที่ 5 - ตอนนี้ใช้ฟังก์ชัน start_job_run และส่ง JobName และอาร์กิวเมนต์หากต้องการ

ขั้นตอนที่ 6 − เมื่องานเริ่มต้น จะมี job_run_id ด้วยข้อมูลเมตาของงาน

ขั้นตอนที่ 7 − ใช้ฟังก์ชัน get_job_run และส่งพารามิเตอร์ RunId จากผลของฟังก์ชันที่แล้ว มันส่งคืนพจนานุกรมเกี่ยวกับสถานะ

ขั้นตอนที่ 8 − ตอนนี้ รับสถานะเฉพาะของงาน สถานะสามารถทำงานต่อได้หากงานไม่เสร็จอย่างอื่น SUCCEEDED/FAILED

ขั้นตอนที่ 9 − จัดการข้อยกเว้นทั่วไปหากมีข้อผิดพลาดขณะตรวจสอบงาน

ตัวอย่าง

ใช้รหัสต่อไปนี้เพื่อเรียกใช้และรับสถานะของงานกาวที่มีอยู่ -

import boto3
from botocore.exceptions import ClientError

def run_glue_job_get_status(job_name, arguments = {}):
   session = boto3.session.Session()
   glue_client = session.client('glue')
   try:
      job_run_id = glue_client.start_job_run(JobName=job_name, Arguments=arguments)
      status_detail = glue_client.get_job_run(JobName=job_name, RunId = job_run_id.get("JobRunId"))
      status = status_detail.get("JobRun").get("JobRunState")
      return status
   except ClientError as e:
      raise Exception( "boto3 client error in run_glue_job_get_status: " + e.__str__())
   except Exception as e:
      raise Exception( "Unexpected error in run_glue_job_get_status: " + e.__str__())

#Get status 1st time
print(run_glue_job_get_status("run_s3_file_job"))
#Get status 2nd time after waiting
time.sleep(10)
print(run_glue_job_get_status("run_s3_file_job"))

ผลลัพธ์

##Get status 1st time
Running
#Get status 2nd time after waiting
SUCCEEDED