mirror of
https://github.com/jlengrand/bugsink.git
synced 2026-03-10 08:01:17 +00:00
42 lines
1.6 KiB
Python
42 lines
1.6 KiB
Python
import contextlib
|
|
import os
|
|
import logging
|
|
import json
|
|
|
|
from django.core.exceptions import ValidationError
|
|
|
|
from snappea.decorators import shared_task
|
|
|
|
from .filestore import get_filename_for_event_id
|
|
|
|
logger = logging.getLogger("bugsink.ingest")
|
|
|
|
|
|
@shared_task
|
|
def digest(event_id, event_metadata):
|
|
from .views import BaseIngestAPIView
|
|
|
|
with open(get_filename_for_event_id(event_id), "rb") as f:
|
|
event_data = json.loads(f.read().decode("utf-8"))
|
|
opened = [get_filename_for_event_id(event_id)]
|
|
|
|
if event_metadata.get("has_minidump"):
|
|
with open(get_filename_for_event_id(event_id, filetype="minidump"), "rb") as f:
|
|
minidump_bytes = f.read()
|
|
opened += [get_filename_for_event_id(event_id, filetype="minidump")]
|
|
else:
|
|
minidump_bytes = None
|
|
|
|
try:
|
|
BaseIngestAPIView.digest_event(event_metadata, event_data, minidump_bytes=minidump_bytes)
|
|
except ValidationError as e:
|
|
logger.warning("ValidationError in digest_event", exc_info=e)
|
|
finally:
|
|
# NOTE: if an SDK misbehaves, and sends the same event_id multiple times in quick succession, the os.unlink
|
|
# below will trigger a FileNotFoundError on the second attempt to delete the file (the events also overwrite
|
|
# each other on-ingest, but that's separately dealt with, showing a "ValidationError in digest_event". We're
|
|
# just catching those and ignoring them (bubble-up is not desirable because it hinders follow-up cleanups)
|
|
for filename in opened:
|
|
with contextlib.suppress(FileNotFoundError):
|
|
os.unlink(filename)
|