Envelope: Ledger Servisi
Topic: qapu.ledger
DLQ: qapu.dlq.ledger
Producer: ledger-service
Ledger servisi, sistemdeki önemli iş olaylarını (kural tetikleme, aksiyon yürütme, otomasyon komutu) denetim amacıyla değiştirilemez biçimde kaydeder. Kayıt başarıyla tamamlandığında ledger.committed.v1, hata durumunda ledger.failed.v1 üretilir.
Event Envanteri
| Event | Ne zaman üretilir? | Consumer | Amaç |
|---|---|---|---|
ledger.committed.v1 | Denetim kaydı başarıyla tablo/depolama alanına yazıldığında | Observer | Görünürlük ve sağlık izleme |
ledger.failed.v1 | Kayıt yazma hatayla sonlandığında | Observer | Hata görünürlüğü ve alarm |
ledger.committed.v1
Özet
| Başlık | Değer |
|---|---|
| Topic | qapu.ledger |
| Producer | ledger-service |
| Consumer | Observer |
| Tetikleyici | rule.triggered.v1, action.executed.v1, automation.job.completed.v1, communication.sent.v1 tüketimi |
| Kritiklik | Orta — denetim izi |
Payload
{
"event": "ledger.committed.v1",
"meta": {
"trace_id": "01a2b3c4d5e6f7g8h9i0",
"producer_service": "ledger-service",
"produced_at": "2026-03-11T15:22:19.000Z",
"process_ms": 20
},
"context": {
"device_id": "400000011D081B70",
"stream_id": 9823412,
"device_time": "2026-03-11T15:22:06Z",
"stream_time": "2026-03-11T15:22:19Z"
},
"data": {
"ledger_id": "ldg_9823412_001",
"source_event": "action.executed.v1",
"source_trace_id": "9f3f...",
"entity_type": "action",
"entity_id": "act_9823412_001",
"committed_at": "2026-03-11T15:22:18.990Z"
},
"error": null
}
Alan Açıklamaları
| Alan | Tip | Zorunlu | Açıklama |
|---|---|---|---|
data.ledger_id | string | Evet | Ledger kaydının benzersiz tanımlayıcısı |
data.source_event | string | Evet | Ledger'ı tetikleyen event adı |
data.source_trace_id | string | Evet | Tetikleyen eventin trace_id'si; iz birleştirme için |
data.entity_type | string | Evet | Kaydedilen varlık türü: rule | action | automation |
data.entity_id | string | Evet | Kaydedilen varlığın kimliği |
ledger.failed.v1
Özet
| Başlık | Değer |
|---|---|
| Topic | qapu.ledger |
| Producer | ledger-service |
| Consumer | Observer Servisi |
| Kritiklik | Yüksek — denetim izi eksik, uyumluluk sorunu doğabilir |
Payload
{
"event": "ledger.failed.v1",
"meta": {
"trace_id": "9f3f...",
"producer_service": "ledger-service",
"produced_at": "2026-03-11T15:22:19.100Z",
"process_ms": 5010
},
"context": {
"device_id": "400000011D081B70",
"stream_id": 9823412,
"device_time": "2026-03-11T15:22:06Z",
"stream_time": "2026-03-11T15:22:19Z"
},
"data": {
"source_event": "action.executed.v1",
"source_trace_id": "9f3f...",
"entity_id": "act_9823412_001"
},
"error": {
"code": "LEDGER_DB_WRITE_TIMEOUT",
"message": "Write timed out after 5000ms",
"stage": "db_write",
"retryable": true
}
}