इस समस्या को हल करने का दृष्टिकोण/एल्गोरिदम
चरण 1 - अपवादों को संभालने के लिए boto3 और botocore एक्सेप्शन्स आयात करें।
चरण 2 - इस फंक्शन के लिए कोई पैरामीटर आवश्यक नहीं है। यह यूज़र अकाउंट के लिए सूचीबद्ध सभी ट्रिगर्स प्राप्त करेगा और फिर प्रत्येक ट्रिगर का मेटाडेटा प्रदर्शित करेगा।
चरण 3 - boto3 लाइब्रेरी का उपयोग करके AWS सत्र बनाएं। सुनिश्चित करें कि region_name डिफ़ॉल्ट प्रोफ़ाइल में उल्लिखित है। यदि नहीं बताया गया है, तो सत्र बनाते समय region_name को स्पष्ट रूप से पास करें।
चरण 4 - Glue के लिए AWS क्लाइंट बनाएं।
चरण 5 - अब list_workflows फंक्शन का उपयोग करके यूज़र अकाउंट में सूचीबद्ध सभी जॉब्स प्राप्त करें।
चरण 6 - batch_get_workflows कॉल करें और पिछले फंक्शन में प्राप्त जॉब नाम पास करें।
चरण 7 - यह list_of_workflows और प्रत्येक वर्कफ़्लो का मेटाडेटा लौटाता है।
चरण 8 - जॉब चेक करते समय यदि कुछ गलत हुआ तो सामान्य अपवाद को संभालें।
उदाहरण
यूज़र अकाउंट में बने प्रत्येक वर्कफ़्लो का विवरण प्राप्त करने के लिए निम्न कोड का उपयोग करें -
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}} 