Làm cách nào để sử dụng Boto3 để lấy chi tiết kết nối từ danh mục Dữ liệu Keo AWS?

Tuyên bố sự cố - Sử dụng thư viện boto3 bằng Python để nhận thông tin chi tiết về kết nối có trong danh mục Dữ liệu keo AWS.

Ví dụ - Nhận chi tiết về định nghĩa kết nối, 'kiểm tra cực quang'.

Phương pháp tiếp cận / Thuật toán để giải quyết vấn đề này

Bước 1 - Nhập các ngoại lệ boto3 và botocore để xử lý các ngoại lệ.

Bước 2 - Chuyển tham số connection_name có định nghĩa cần kiểm tra.

Bước 3 - Tạo phiên AWS bằng thư viện boto3. Đảm bảo rằng tên miền được đề cập trong hồ sơ mặc định. Nếu nó không được đề cập, thì hãy chuyển rõ ràng region_name trong khi tạo phiên.

Bước 4 - Tạo ứng dụng AWS cho keo dán.

Bước 5 - Gọi get_connection chức năng và chuyển tên_kết nối thành Tên tham số.

Bước 6 - Nó sẽ tìm nạp thông tin chi tiết về định nghĩa kết nối từ Danh mục dữ liệu keo AWS.

Bước 7 - Xử lý ngoại lệ chung nếu có sự cố xảy ra trong khi kiểm tra công việc.

Ví dụ

Sử dụng mã sau để tìm định nghĩa về kết nối trong danh mục Dữ liệu keo AWS -

import boto3
from botocore.exceptions import ClientError

def get_details_of_a_connection(connection_name):
   session = boto3.session.Session()
   glue_client = session.client('glue')
   try:
      response = glue_client.get_connection(Name= connection_name)
      return response
   except ClientError as e:
      raise Exception("boto3 client error in get_details_of_a_connection: " + e.__str__())
   except Exception as e:
      raise Exception("Unexpected error in get_details_of_a_connection: " + e.__str__())
print(get_details_of_a_connection("aurora-poc"))

Đầu ra

{'Connection': {'Name': 'aurora-poc', 'ConnectionType': 'JDBC',
'ConnectionProperties': {'JDBC_CONNECTION_URL': 'jdbc:postgresql://abcpostgresql-cluster.cluster-abc.us-east-1.rds.amazonaws.com:0132/abc,
'JDBC_ENFORCE_SSL': 'false', 'PASSWORD': '******', 'USERNAME':
'abc***'}, 'PhysicalConnectionRequirements': {'SubnetId': 'subnet351*****', 'SecurityGroupIdList': ['sg-caa******', 'sg-*************'],
'AvailabilityZone': 'us-east-1c'}, 'CreationTime':
datetime.datetime(2020, 11, 18, 12, 38, 29, 625000, tzinfo=tzlocal()),
'LastUpdatedTime': datetime.datetime(2020, 11, 18, 12, 51, 16, 59000,
tzinfo=tzlocal())}, 'ResponseMetadata': {'RequestId': '6f13524b-4175-
454b-bc60-c7f408967098', 'HTTPStatusCode': 200, 'HTTPHeaders': {'date':
'Sun, 28 Feb 2021 11:19:18 GMT', 'content-type': 'application/x-amzjson-1.1', 'content-length': '523', 'connection': 'keep-alive', 'x-amznrequestid': '6f13524b-*****************7098'}, 'RetryAttempts': 0}}