Add telemetry related calls (for pipeline monitoring)

[nuclearcat]

Related to: kernelci/kernelci-pipeline#1419

[Copilot]

Pull request overview

This PR adds telemetry-related API endpoints for pipeline monitoring, as referenced in issue #1419. The changes introduce a separate telemetry collection to track pipeline execution events with higher volume and different query patterns than the existing EventHistory collection.

Changes:

• Added four new telemetry endpoints: POST /telemetry for bulk event insertion, GET /telemetry for querying events, GET /telemetry/stats for aggregated statistics, and GET /telemetry/anomalies for anomaly detection
• Added database support methods (insert_many, aggregate) to handle telemetry operations
• Integrated TelemetryEvent model from kernelci.api.models into the database collection mapping

Reviewed changes

Copilot reviewed 2 out of 2 changed files in this pull request and generated 16 comments.

File	Description
api/main.py	Adds four telemetry endpoints with authentication, filtering, aggregation, and anomaly detection capabilities
api/db.py	Adds TelemetryEvent to collection mapping and implements insert_many and aggregate methods for bulk operations

---

💡 Add Copilot custom instructions for smarter, more guided reviews. Learn how to get started.

[Copilot]

Misleading or incorrect documentation. The docstring states "This is rule-based anomaly detection using thresholded empirical rates..." but this endpoint (get_telemetry_stats) only provides aggregated statistics without any anomaly detection logic. Anomaly detection is actually performed by the get_telemetry_anomalies endpoint. This docstring should describe the stats aggregation functionality, not anomaly detection.

[Copilot]

Missing error handling for datetime.fromisoformat(). If 'since' or 'until' parameters contain invalid ISO 8601 format strings, this will raise a ValueError that is not caught, resulting in an unhandled 500 error instead of a user-friendly 400 Bad Request. Wrap these calls in a try-except block and raise HTTPException with status 400.

Suggested change

	if since:
	ts_filter['$gte'] = datetime.fromisoformat(since)
	if until:
	ts_filter['$lte'] = datetime.fromisoformat(until)
	try:
	if since:
	ts_filter['$gte'] = datetime.fromisoformat(since)
	if until:
	ts_filter['$lte'] = datetime.fromisoformat(until)
	except ValueError as exc:
	raise HTTPException(
	status_code=status.HTTP_400_BAD_REQUEST,
	detail="Invalid 'since' or 'until' timestamp; expected ISO 8601 format.",
	) from exc

[nuclearcat]

done