60 lines
1.9 KiB
Python
60 lines
1.9 KiB
Python
import json
|
|
import redis
|
|
from config import Config
|
|
|
|
CALENDAR_SYNC_LOCK_KEY = 'calendar_sync_lock'
|
|
|
|
config = {
|
|
'type': 'cron',
|
|
'name': 'Calendar Sync Cron Job',
|
|
'description': 'Führt den Calendar Sync alle 15 Minuten automatisch aus',
|
|
'cron': '*/15 * * * *', # Alle 15 Minuten
|
|
'emits': ['calendar.sync.triggered']
|
|
}
|
|
|
|
async def handler(event, context):
|
|
try:
|
|
# Prüfe ob bereits ein Sync läuft
|
|
redis_client = redis.Redis(
|
|
host=Config.REDIS_HOST,
|
|
port=int(Config.REDIS_PORT),
|
|
db=int(Config.REDIS_DB_CALENDAR_SYNC),
|
|
socket_timeout=Config.REDIS_TIMEOUT_SECONDS
|
|
)
|
|
|
|
if redis_client.get(CALENDAR_SYNC_LOCK_KEY):
|
|
context.logger.info("Calendar Sync Cron: Sync bereits aktiv, überspringe")
|
|
return {
|
|
'status': 'skipped',
|
|
'reason': 'sync_already_running',
|
|
'triggered_by': 'cron'
|
|
}
|
|
|
|
# Setze Lock für 30 Minuten (Sync sollte max 30 Minuten dauern)
|
|
redis_client.set(CALENDAR_SYNC_LOCK_KEY, 'cron', ex=1800)
|
|
context.logger.info("Calendar Sync Cron: Lock gesetzt, starte automatische Synchronisation alle 15 Minuten")
|
|
|
|
# Emit Event für den Sync
|
|
await context.emit({
|
|
"topic": "calendar.sync.triggered",
|
|
"data": {
|
|
"body": {
|
|
"full_content": True, # Cron verwendet immer volle Details
|
|
"triggered_by": "cron"
|
|
}
|
|
}
|
|
})
|
|
|
|
context.logger.info("Calendar Sync Cron: Event wurde emittiert")
|
|
return {
|
|
'status': 'completed',
|
|
'triggered_by': 'cron'
|
|
}
|
|
|
|
except Exception as e:
|
|
context.logger.error(f"Fehler beim Cron-Job: {e}")
|
|
return {
|
|
'status': 'error',
|
|
'error': str(e)
|
|
}
|