diff --git a/worker_sns.py b/worker_sns.py index b7899f9..3226590 100755 --- a/worker_sns.py +++ b/worker_sns.py @@ -34,9 +34,13 @@ SMTP_PASS = os.environ.get('SMTP_PASS') # Graceful shutdown shutdown_requested = False -# DynamoDB Ressource (neu im Worker!) -dynamo = boto3.resource('dynamodb', region_name=AWS_REGION) -msg_table = dynamo.Table('ses-outbound-messages') +# DynamoDB Ressource für Bounce-Lookup +try: + dynamo = boto3.resource('dynamodb', region_name=AWS_REGION) + msg_table = dynamo.Table('ses-outbound-messages') +except Exception as e: + log(f"Warning: Could not connect to DynamoDB: {e}", 'WARNING') + msg_table = None def get_bucket_name(domain): """Konvention: domain.tld -> domain-tld-emails"""