이벤트 계약
쿼리가 예상하는 필드
| 필드 | 유형 | 그것이 존재하는 이유 |
|---|---|---|
| timestamp_utc | Timestamp | 실행이 완료되거나 실패한 경우. |
| job_name | Utf8 | 안정적인 논리적 작업 이름입니다. |
| status | Utf8 | 성공 또는 실패. |
| attempt | Int64 | 1회 실행 시도. |
| duration_ms | Float64 | 시도 기간. |
DataFusion SQL
쿼리 복사
sql
SELECT
job_name,
COUNT(*) AS attempts,
SUM(CASE WHEN attempt > 1 THEN 1 ELSE 0 END) AS retries,
SUM(CASE WHEN status = 'failed' THEN 1 ELSE 0 END) AS failures,
100.0 * SUM(CASE WHEN attempt > 1 THEN 1 ELSE 0 END)
/ NULLIF(COUNT(*), 0) AS retry_rate_pct,
approx_percentile_cont(duration_ms, 0.95) AS p95_duration_ms
FROM job_runs
WHERE timestamp_utc >= now() - INTERVAL '7 days'
GROUP BY job_name
ORDER BY retry_rate_pct DESC, failures DESC;이 읽기 전용 쿼리는 빈 유형의 테이블에 대해 계획되고 실행됩니다. 아파치 DataFusion 45.2.0. 결정론적 샘플 출력은 합성되어 별도로 검토됩니다. 자신의 데이터에 대해 필드 유형, 임계값 및 비즈니스 정의를 검증합니다. 테스트 방법론을 읽어보세요.
쿼리 결과
작업별 재시도율
이메일에 절대적인 재시도 횟수가 더 많더라도 구독 동기화에 주의를 기울여야 합니다.
sync_subscription
30%
generate_report
12.5%
send_email
0%
| job_name | attempts | retries | failures | retry_rate_pct | p95_duration_ms |
|---|---|---|---|---|---|
| sync_subscription | 10 | 3 | 2 | 30 | 8,000 |
| generate_report | 8 | 1 | 1 | 12.5 | 12,000 |
| send_email | 10 | 0 | 0 | 0 | 900 |
합성 예제 출력. 운영 결정에 사용하기 전에 자체 이벤트 스키마 및 임계값에 대해 쿼리를 실행하세요.
예제 재현
공공 픽스처 다운로드
JSON 번들은 타입이 지정된 이벤트 계약을 포함합니다. reproducible 입력 행, 정확한 SQL, 예상 출력, 검토 참고 사항 및 엔진 버전. CSV에는 표시된 결과가 포함됩니다.
SQL 작동 방식
- 1논리적 작업 대신 시도 횟수를 계산하면 재시도로 인한 추가 실행 로드가 의도적으로 노출됩니다.
- 2재시도율 분모는 모든 시도입니다. 논리적 작업 분모를 선호하는 경우 job_id를 포함하고 고유한 작업 ID를 계산합니다.
- 3p95 기간은 빠른 일시적 재시도와 작업자 용량을 소비하는 비용이 많이 드는 실행을 구별하는 데 도움이 됩니다.
결정해야 할 극단적인 경우
- 예약된 재시도는 예상된 동작일 수 있습니다. 재시도 정책을 변경하기 전에 error_type로 분할하세요.
- 여러 시도가 하나의 논리적 작업 단위에 속하는 경우 안정적인 job_id를 사용하십시오.
- 배달 못한 편지 이벤트는 복구가 소진되었음을 나타내므로 별도로 보고해야 합니다.
추천 대시보드
- 막대형 차트: retry_rate_pct by job_name
- 꺾은선형 차트: 일별 오류 및 job_name
- 표: 고객 및 오류 컨텍스트와 관련된 최신 최종 실패
레시피를 활용해 보세요
관련 계측 및 가이드
분석 계속하기
실제 이벤트에서 실행
테이블을 만들고, 필드를 조정하고, 결과를 저장하세요.
무료로 시작하고, 구조화된 이벤트를 보내고, 쿼리 결과를 차트, 공유 대시보드 위젯 또는 알림 입력으로 사용하세요.