egress_deliveries
egress_deliveries, Egress Servisinin dis sistem gonderim denemelerini ve sonuclarini izlemek icin kullandigi operasyonel kayit tablosudur.
Bu tablo ile "hangi event ne zaman hangi hedefe gitti", "kac deneme yapildi", "neden fail oldu" sorulari izlenebilir hale gelir.
Kolonlar
| Kolon | Tip | Null | Anlami |
|---|---|---|---|
id | bigint | hayır | Delivery kaydi birincil anahtari |
policy_id | bigint | hayır | Kullanilan policy; egress_policies.id |
trace_id | varchar(128) | hayır | Dagitik izleme kimligi |
source_event | varchar(64) | hayır | Kaynak event adi |
source_ref_id | bigint | evet | Kaynak referans (stream_id, run_id vb.) |
device_id | varchar(21) | evet | Ilgili cihaz |
target_system | varchar(80) | hayır | Hedef sistem kodu |
attempt_no | int | hayır | Kacinci deneme |
status | varchar(16) | hayır | sent | failed | dlq |
http_status | int | evet | HTTP tabanli hedeflerde donen status |
request_body_hash | varchar(128) | evet | Outbound payload hash'i |
response_excerpt | text | evet | Hedef cevabinin kisaltilmis ozet metni |
error_code | varchar(64) | evet | Hata kodu |
error_message | varchar(255) | evet | Hata aciklamasi |
retryable | boolean | evet | Hata tekrar denenebilir mi |
sent_at | timestamp | evet | Basarili gonderim zamani |
next_retry_at | timestamp | evet | Bir sonraki retry zamani |
create_time | timestamp | hayır | Kayit olusturma zamani |
update_time | timestamp | hayır | Son guncelleme zamani |
İndeksler
| İndeks | Tip | Açıklama |
|---|---|---|
id | Primary Key | Tablo birincil anahtarı |
(policy_id, create_time) | Index | Policy bazli zaman sirali denetim |
(trace_id) | Index | Tek akisin tum delivery adimlarini takip |
(status, next_retry_at) | Index | Retry worker tarafi kuyruk taramasi |
Örnek Kayıtlar
- Basarili Gonderim
- DLQ ile Sonlanan Hata
{
"id": 9001,
"policy_id": 101,
"trace_id": "eg-9f3f",
"source_event": "window.ready.v1",
"source_ref_id": 9823412,
"device_id": "400000011D081B70",
"target_system": "acme-crm",
"attempt_no": 1,
"status": "sent",
"http_status": 200,
"request_body_hash": "sha256:ab12...",
"response_excerpt": "ok",
"error_code": null,
"error_message": null,
"retryable": null,
"sent_at": "2026-04-15 10:30:10",
"next_retry_at": null,
"create_time": "2026-04-15 10:30:10",
"update_time": "2026-04-15 10:30:10"
}
Özet: Ilk denemede basariyla teslim edilmis telemetri aktarimi.
{
"id": 9002,
"policy_id": 102,
"trace_id": "eg-9f40",
"source_event": "automation.job.failed.v1",
"source_ref_id": 9122,
"device_id": "400000011D081B70",
"target_system": "delta-scada",
"attempt_no": 3,
"status": "dlq",
"http_status": 504,
"request_body_hash": "sha256:bb77...",
"response_excerpt": "gateway timeout",
"error_code": "EGRESS_HTTP_TIMEOUT",
"error_message": "partner endpoint timeout",
"retryable": false,
"sent_at": null,
"next_retry_at": null,
"create_time": "2026-04-15 10:31:12",
"update_time": "2026-04-15 10:31:12"
}
Özet: Retry limiti sonrasinda DLQ'ya dusen ve kalici hata olarak isaretlenen aktarim.