วิธีดึงรายละเอียด Notification Configuration ของ S3 Bucket ด้วย Boto3 และ AWS Client

ข้อกำหนดปัญหา

ใช้ไลบรารี Boto3 ใน Python เพื่อดึง Notification Configuration ของ S3 Bucket เช่น หา Notification Configuration Details ของ Bucket_1 ใน S3

ขั้นตอนการแก้ปัญหา

1. ขั้นตอนที่ 1 – นำเข้า boto3 และ botocore.exceptions เพื่อจัดการข้อยกเว้น
2. ขั้นตอนที่ 2 – ใช้ bucket_name เป็นพารามิเตอร์ในฟังก์ชัน
3. ขั้นตอนที่ 3 – สร้าง AWS Session ด้วย Boto3
4. ขั้นตอนที่ 4 – สร้าง AWS Client สำหรับ S3
5. ขั้นตอนที่ 5 – ใช้ฟังก์ชัน get_bucket_notification_configuration ส่งชื่อ Bucket
6. ขั้นตอนที่ 6 – คืนค่า Dictionary ที่มีรายละเอียดเกี่ยวกับ S3 หากไม่ได้ตั้งค่า Notification จะคืนค่า NONE
7. ขั้นตอนที่ 7 – จัดการข้อยกเว้นทั่วไปหากเกิดข้อผิดพลาดขณะลบไฟล์

ตัวอย่างโค้ด

ใช้โค้ดต่อไปนี้เพื่อดึง Notification Configuration Details:

import boto3
from botocore.exceptions import ClientError

def get_bucket_notification_configuration_of_s3(bucket_name):
    session = boto3.session.Session()
    s3_client = session.client('s3')
    try:
        result = s3_client.get_bucket_notification_configuration(Bucket=bucket_name)
    except ClientError as e:
        raise Exception("boto3 client error in get_bucket_notification_configuration_of_s3: " + e.__str__())
    except Exception as e:
        raise Exception("Unexpected error in get_bucket_notification_configuration_of_s3 function: " + e.__str__())
    return result

print(get_bucket_notification_configuration_of_s3("Bucket_1"))

ผลลัพธ์

{
    'TopicConfigurations': [
        {
            'Id': 'string',
            'TopicArn': 'string',
            'Events': [
                's3:ReducedRedundancyLostObject'|'s3:ObjectCreated:*'|'s3:ObjectCreated:Put'|'s3:ObjectCreated:Post'|'s3:ObjectCreated:Copy'|'s3:ObjectCreated:CompleteMultipartUpload'|'s3:ObjectRemoved:*'|'s3:ObjectRemoved:Delete'|'s3:ObjectRemoved:DeleteMarkerCreated'|'s3:ObjectRestore:*'|'s3:ObjectRestore:Post'|'s3:ObjectRestore:Completed'|'s3:Replication:*'|'s3:Replication:OperationFailedReplication'|'s3:Replication:OperationNotTracked'|'s3:Replication:OperationMissedThreshold'|'s3:Replication:OperationReplicateAfterThreshold'
            ],
            'Filter': {
                'Key': {
                    'FilterRules': [
                        {
                            'Name': 'prefix'|'suffix',
                            'Value': 'string'
                        }
                    ]
                }
            }
        }
    ],
    'QueueConfigurations': [
        {
            'Id': 'string',
            'QueueArn': 'string',
            'Events': [
                's3:ReducedRedundancyLostObject'|'s3:ObjectCreated:*'|'s3:ObjectCreated:Put'|'s3:ObjectCreated:Post'|'s3:ObjectCreated:Copy'|'s3:ObjectCreated:CompleteMultipartUpload'|'s3:ObjectRemoved:*'|'s3:ObjectRemoved:Delete'|'s3:ObjectRemoved:DeleteMarkerCreated'|'s3:ObjectRestore:*'|'s3:ObjectRestore:Post'|'s3:ObjectRestore:Completed'|'s3:Replication:*'|'s3:Replication:OperationFailedReplication'|'s3:Replication:OperationNotTracked'|'s3:Replication:OperationMissedThreshold'|'s3:Replication:OperationReplicateAfterThreshold'
            ],
            'Filter': {
                'Key': {
                    'FilterRules': [
                        {
                            'Name': 'prefix'|'suffix',
                            'Value': 'string'
                        }
                    ]
                }
            }
        }
    ],
    'LambdaFunctionConfigurations': [
        {
            'Id': 'string',
            'LambdaFunctionArn': 'string',
            'Events': [
                's3:ReducedRedundancyLostObject'|'s3:ObjectCreated:*'|'s3:ObjectCreated:Put'|'s3:ObjectCreated:Post'|'s3:ObjectCreated:Copy'|'s3:ObjectCreated:CompleteMultipartUpload'|'s3:ObjectRemoved:*'|'s3:ObjectRemoved:Delete'|'s3:ObjectRemoved:DeleteMarkerCreated'|'s3:ObjectRestore:*'|'s3:ObjectRestore:Post'|'s3:ObjectRestore:Completed'|'s3:Replication:*'|'s3:Replication:OperationFailedReplication'|'s3:Replication:OperationNotTracked'|'s3:Replication:OperationMissedThreshold'|'s3:Replication:OperationReplicateAfterThreshold'
            ],
            'Filter': {
                'Key': {
                    'FilterRules': [
                        {
                            'Name': 'prefix'|'suffix',
                            'Value': 'string'
                        }
                    ]
                }
            }
        }
    ]
}

หมายเหตุ: Output นี้ขึ้นอยู่กับ Settings/Permissions ของ Bucket จะละเว้น Result หาก Settings/Permissions บางอย่างเป็น Default หรือไม่ได้ตั้งค่า เช่นเดียวกัน หากไม่ได้ตั้งค่า Notification สำหรับ Bucket จะคืนค่า NONE