AWS S3'ten CloudFront Ön Belleği Temizlemek: Otomasyonu Kodla

1pip install boto3

1import boto3
2from datetime import datetime
3
4client = boto3.client('cloudfront', region_name='us-east-1')
5
6DISTRIBUTION_ID = 'E1234ABCD'
7PATHS = ['/index.html', '/assets/*', '/images/logo.png']
8
9def invalidate_cache(paths):
10try:
11response = client.create_invalidation(
12DistributionId=DISTRIBUTION_ID,
13InvalidationBatch={
14'Paths': {
15'Quantity': len(paths),
16'Items': paths
17},
18'CallerReference': str(datetime.now().timestamp())
19}
20)
21print(f" Invalidation başlatıldı: {response['Invalidation']['Id']}")
22print(f" Durum: {response['Invalidation']['Status']}")
23return response['Invalidation']['Id']
24except Exception as e:
25print(f" Hata: {e}")
26return None
27
28if __name__ == '__main__':
29invalidate_cache(PATHS)

1Invalidation başlatıldı: I2ABC3DEF4GHI
2Durum: InProgress

1import json
2import boto3
3import os
4
5client = boto3.client('cloudfront')
6DISTRIBUTION_ID = os.environ['DISTRIBUTION_ID']
7
8def lambda_handler(event, context):
9for record in event['Records']:
10bucket = record['s3']['bucket']['name']
11key = record['s3']['object']['key']
12
13# S3 key'i CloudFront path'ine çevir
14path = f'/{key}'
15
16client.create_invalidation(
17DistributionId=DISTRIBUTION_ID,
18InvalidationBatch={
19'Paths': {'Quantity': 1, 'Items': [path]},
20'CallerReference': key
21}
22)
23
24return {'statusCode': 200, 'body': 'Invalidation completed'}