Structure OpenTofu environments
This commit is contained in:
@@ -0,0 +1,48 @@
|
||||
import json
|
||||
import os
|
||||
|
||||
|
||||
def lambda_handler(event, context):
|
||||
app_name = os.environ.get("APP_NAME", "Quantum")
|
||||
bucket_name = os.environ.get("BUCKET_NAME", "unknown")
|
||||
secret_name = os.environ.get("SECRET_NAME", "unknown")
|
||||
|
||||
records = event.get("Records", [])
|
||||
|
||||
processed = []
|
||||
for record in records:
|
||||
body = record.get("body", "{}")
|
||||
|
||||
try:
|
||||
payload = json.loads(body)
|
||||
except json.JSONDecodeError:
|
||||
payload = {"raw": body}
|
||||
|
||||
processed.append(
|
||||
{
|
||||
"messageId": record.get("messageId"),
|
||||
"payload": payload,
|
||||
}
|
||||
)
|
||||
|
||||
print(
|
||||
json.dumps(
|
||||
{
|
||||
"app": app_name,
|
||||
"bucket": bucket_name,
|
||||
"secret": secret_name,
|
||||
"processedCount": len(processed),
|
||||
"records": processed,
|
||||
}
|
||||
)
|
||||
)
|
||||
|
||||
return {
|
||||
"statusCode": 200,
|
||||
"body": json.dumps(
|
||||
{
|
||||
"message": "Quantum event batch processed",
|
||||
"processedCount": len(processed),
|
||||
}
|
||||
),
|
||||
}
|
||||
Reference in New Issue
Block a user