সমাধানের পদ্ধতি/অ্যালগরিদম
ধাপ ১ − boto3 এবং botocore এক্সসেপশন ইম্পোর্ট করে এক্সসেপশন হ্যান্ডল করা।
ধাপ ২ − এই ফাংশনের জন্য কোনো প্যারামিটার প্রয়োজন নেই। এটি ইউজার অ্যাকাউন্টের জন্য লিস্ট করা সকল ট্রিগার আনয়ন করবে এবং তারপর প্রতিটি ট্রিগারের মেটাডেটা প্রদর্শন করবে।
ধাপ ৩ − boto3 লাইব্রেরি ব্যবহার করে AWS সেশন তৈরি করা। নিশ্চিত করুন region_name ডিফল্ট প্রোফাইলে ذکر করা আছে। না থাকলে সেশন তৈরি করার সময় স্পষ্টভাবে region_name পাস করুন।
ধাপ ৪ − Glue-এর জন্য AWS ক্লায়েন্ট তৈরি করা।
ধাপ ৫ − এখন list_workflows ফাংশন ব্যবহার করে ইউজার অ্যাকাউন্টে লিস্ট করা সকল জব পাওয়া।
ধাপ ৬ − batch_get_workflows কল করা এবং আগের ফাংশনে পাওয়া জব নামগুলো পাস করা।
ধাপ ৭ − এটি list_of_workflows এবং প্রতিটি ওয়ার্কফ্লোর মেটাডেটা রিটার্ন করে।
ধাপ ৮ − জব চেক করার সময় যদি কিছু ভুল হয় তবে জেনেরিক এক্সসেপশন হ্যান্ডল করা।
উদাহরণ
ইউজার অ্যাকাউন্টে তৈরি প্রতিটি ওয়ার্কফ্লোর ডিটেইলস আনয়ন করতে নিচের কোড ব্যবহার করুন −
import boto3 from botocore.exceptions import ClientError def get_resource_maetadata_of_workflows(): session = boto3.session.Session() glue_client = session.client('glue') try: list_of_workflows = glue_client.list_workflows() response = glue_client.batch_get_workflows(Names=list_of_workflows['Workflows']) return list_of_workflows, response except ClientError as e: raise Exception("boto3 client error in get_resource_maetadata_of_workflows: " + e.__str__()) except Exception as e: raise Exception("Unexpected error in get_resource_maetadata_of_workflows: " + e.__str__()) a, b = get_resource_maetadata_of_workflows() # ওয়ার্কফ্লোর লিস্ট print(a) # প্রতিটি ওয়ার্কফ্লোর রিসোর্স মেটাডেটা print(b)আউটপুট
# ওয়ার্কফ্লোর লিস্ট {'Workflows': ['dev-aiml-naviga-ods-load'], 'ResponseMetadata': {'RequestId': '556890ce-bcd1-4bb0-9c33-3ae1db13f3a9', 'HTTPStatusCode': 200, 'HTTPHeaders': {'date': 'Sat, 27 Feb 2021 13:57:37 GMT', 'contenttype': 'application/x-amz-json-1.1', 'content-length': '91', 'connection': 'keep-alive', 'x-amzn-requestid': '556890ce-bcd1-4bb0-9c33-3ae1db13f3a9'}, 'RetryAttempts': 0}} # প্রতিটি ওয়ার্কফ্লোর রিসোর্স মেটাডেটা {'Workflows': [{'Name': 'dev-aiml-naviga-ods-load', 'DefaultRunProperties': {}, 'CreatedOn': datetime.datetime(2020, 5, 27, 3, 10, 57, 967000, tzinfo=tzlocal()), 'LastModifiedOn': datetime.datetime(2020, 5, 27, 3, 10, 57, 967000, tzinfo=tzlocal())}, 'StartedOn': datetime.datetime(2021, 2, 3, 16, 14, 48, 795000, tzinfo=tzlocal()), 'CompletedOn': datetime.datetime(2021, 2, 3, 16, 28, 6, 207000, tzinfo=tzlocal()), 'Status': 'COMPLETED', 'Statistics': {'TotalActions': 3, 'TimeoutActions': 0, 'FailedActions': 0, 'StoppedActions': 0, 'SucceededActions': 3, 'RunningActions': 0}}], 'MissingWorkflows': [], '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}} 