Skip to main content

Envelope: Action Servisi

Topic: qapu.action
DLQ: qapu.dlq.action
Producer: action-service

Action servisi, tetiklenen kurallar karşısında tanımlı aksiyonları yürütür: bildirim gönderme, otomasyon komutu veya Ledger kaydı. Aksiyon talebi iletildiğinde action.execute.requested.v1, başarıyla tamamlandığında action.executed.v1, hata durumunda action.failed.v1 üretilir.

Event Envanteri

EventNe zaman üretilir?ConsumerAmaç
action.execute.requested.v1Kural tetiklemesi bir aksiyon gerektirdiğindeCommunication / Automation / Ledgerİlgili alt servise iş yükü iletmek
action.executed.v1Aksiyon başarıyla tamamlandığındaLedger, ObserverDenetim kaydı ve görünürlük
action.failed.v1Aksiyon yürütme sırasında hata olduğundaObserverHata görünürlüğü ve retry kararı

action.execute.requested.v1

Özet

BaşlıkDeğer
Topicqapu.action
Produceraction-service
ConsumerCommunication Servisi, Automation Servisi, Ledger Servisi
Tetikleyicirule.triggered.v1 tüketimi
KritiklikYüksek — bildirim veya otomasyon zincirine girer

Payload

{
"event": "action.execute.requested.v1",
"meta": {
"trace_id": "01a2b3c4d5e6f7g8h9i0",
"producer_service": "action-service",
"produced_at": "2026-03-11T15:22:14.000Z",
"process_ms": 10
},
"context": {
"device_id": "400000011D081B70",
"raw_id": 12345,
"stream_id": 9823412,
"device_time": "2026-03-11T15:22:06Z",
"stream_time": "2026-03-11T15:22:14.000Z",
"iccid": null,
"imei": null,
"firmware": "2.3.0"
},
"data": {
"action_id": "act_9823412_001",
"rule_id": "rule_voltage_high_001",
"action_type": "notify",
"target_channel": "sms",
"recipient": "+905XX000000",
"template_id": "voltage_high_warning",
"payload": {
"device_id": "400000011D081B70",
"metric": "voltage_rms_l1",
"measured_value": 257.4,
"threshold": 253.0
}
},
"error": null
}

Alan Açıklamaları

AlanTipZorunluAçıklama
data.action_idstringEvetAksiyonun benzersiz tanımlayıcısı
data.action_typestringEvetnotify | automate | log
data.target_channelstringnotify isesms | email | push | whatsapp
data.template_idstringnotify iseMesaj şablonu
data.payloadobjectHayırŞablona aktarılan bağlam verisi

action.executed.v1

Özet

BaşlıkDeğer
Topicqapu.action
Produceraction-service
ConsumerLedger Servisi, Observer
TetikleyiciCommunication/Automation servisinin başarı bildirimi alındığında
KritiklikOrta — denetim ve görünürlük kaydı

Payload

{
"event": "action.executed.v1",
"meta": {
"trace_id": "01a2b3c4d5e6f7g8h9i1",
"producer_service": "action-service",
"produced_at": "2026-03-11T15:22:16.800Z",
"process_ms": 1800
},
"context": {
"device_id": "400000011D081B70",
"raw_id": 12345,
"stream_id": 9823412,
"device_time": "2026-03-11T15:22:06Z",
"stream_time": "2026-03-11T15:22:16Z",
"iccid": null,
"imei": null,
"firmware": "2.3.0"
},
"data": {
"action_id": "act_9823412_001",
"rule_id": "rule_voltage_high_001",
"action_type": "notify",
"target_channel": "sms",
"duration_ms": 1800
},
"error": null
}

action.failed.v1

Özet

BaşlıkDeğer
Topicqapu.action
Produceraction-service
ConsumerObserver Servisi
KritiklikOrta — aksiyon tamamlanmadı; Observer retry/eskalasyon kararı verir

Payload

{
"event": "action.failed.v1",
"meta": {
"trace_id": "01a2b3c4d5e6f7g8h9i2",
"producer_service": "action-service",
"produced_at": "2026-03-11T15:22:16.900Z",
"process_ms": 5010
},
"context": {
"device_id": "400000011D081B70",
"raw_id": 12345,
"stream_id": 9823412,
"device_time": "2026-03-11T15:22:06Z",
"stream_time": "2026-03-11T15:22:16Z",
"iccid": null,
"imei": null,
"firmware": null
},
"data": {
"action_id": "act_9823412_001",
"rule_id": "rule_voltage_high_001",
"action_type": "notify",
"target_channel": "sms"
},
"error": {
"failed_stage": "action",
"error_code": "ACTION_SMS_TIMEOUT",
"error_message": "SMS gateway did not respond within 5s",
"failed_at": "2026-03-11T15:22:16Z"
}
}