national_dashboard
Alur kompilasi rollup stabilitas nasional harian, sintesis narasi analisis intelijen 3 blok, dan pengisian indeks Elasticsearch national_dashboard.
Pipeline Data: national_dashboard (Rollup Stabilitas Nasional)
Pipeline ini bertugas mengompilasi statistik situasi keamanan, ketertiban, dan stabilitas nasional harian dari 38 provinsi di Indonesia ke dalam indeks Elasticsearch national_dashboard.
Selain memadatkan angka total event dan rata-rata skor risiko nasional (national_risk), worker nexa-aggregation pada pipeline ini juga menerbitkan tiga blok narasi analitik intelijen resmi (Daily Intelligence Narrative) yang disajikan langsung ke jajaran pimpinan pada panel Analisa Intelijen Nasional di layar /dashboard/overview.
1. Ringkasan Arsitektur Alur
[Elasticsearch: province_dashboard & articles]
(Agregat 38 provinsi dan artikel berita berlabel taksonomi)
│
▼ (Batch Harian, Jendela 24 Jam)
[nexa-aggregation Worker]
• Rollup metrik total event dan sebaran status risiko nasional
• Hitung rata-rata tertimbang skor risiko nasional (national_risk)
• Rekapitulasi sebaran isu per pilar (taxonomy_summary.by_pillar)
• Sintesis 3 blok narasi intelijen harian (intelligence_analysis)
│
▼
[Elasticsearch: national_dashboard]
(1 dokumen per jendela harian, period: 24h, doc_version: 3)
│
├─────────────────────────────────────┐
▼ ▼
[GET /overview/intel-analysis] [GET /overview/national-risk]
(3 Blok Narasi Intelijen Pimpinan) (Kartu KPI Ringkasan Stabilitas)Alur Aggregation Worker (`nexa-aggregation`)
Kompilasi metrik statistik, rolling trends, agregasi sentimen wilayah, dan caching
Menarik subset dokumen berita dan media sosial berdasarkan jendela waktu pemantauan.
Menghitung agregasi volume postingan, rasio sentimen positif/negatif, dan lonjakan isu seketika.
Mengelompokkan isu berdasarkan 38 provinsi di Indonesia untuk kebutuhan visualisasi peta digital twin.
Menyimpan tabel agregasi ke database relasional dan memperbarui cache Redis untuk respons API instan.
2. Tiga Blok Narasi Analisis Intelijen (Intelligence Analysis)
Worker nexa-aggregation menghasilkan teks narasi intelijen terstruktur yang disimpan pada objek intelligence_analysis di dalam dokumen national_dashboard:
high_risk_insight(Sorotan Isu Risiko Tinggi): Menganalisis provinsi atau klaster isu yang mengalami eskalasi ancaman paling menonjol pada hari tersebut (misalnya dinamika unjuk rasa, sengketa lahan, atau gangguan kamtibmas skala besar).emerging_threats(Ancaman Baru yang Muncul): Mengidentifikasi isu-isu yang baru pertama kali muncul atau menunjukkan akselerasi percepatan percakapan signifikan yang berpotensi menjadi krisis lanjutan.strategic_outlook(Prospek Strategis & Rekomendasi Situasi): Memberikan gambaran proyeksi situasi kamtibmas untuk 24–48 jam ke depan serta poin atensi bagi pimpinan komando kewilayahan.
Konsistensi Narasi Harian
Blok teks narasi ini diterbitkan apa adanya oleh nexa-aggregation tanpa modifikasi manual di backend API. Dokumen ber-versi document_version >= 3 menjadi standar rujukan narasi resmi bagi modul /dashboard/overview dan /dashboard/media.
3. Struktur Dokumen di Elasticsearch national_dashboard
Worker menerbitkan tepat satu dokumen per hari (berjangkar pada jendela waktu generated_from.end):
{
"_id": "national_2026-09-26",
"document_version": 3,
"period": "24h",
"national_risk": 0.38,
"total_events": 4097,
"measured_provinces": 38,
"status_distribution": {
"AMAN": 24,
"WASPADA": 10,
"SIAGA": 3,
"AWAS": 1
},
"taxonomy_summary": {
"by_pillar": {
"kamtibmas": 1420,
"politik": 980,
"ekonomi": 850,
"sosial": 540,
"hukum": 307
}
},
"intelligence_analysis": {
"high_risk_insight": "Eskalasi konsentrasi massa di wilayah Jawa Barat terkait penetapan upah minimum regional memerlukan kesiapsiagaan pengamanan objek vital.",
"emerging_threats": "Terdeteksi peningkatan narasi polarisasi berbasis identitas di ranah digital menjelang penetapan pasangan calon Pilkada.",
"strategic_outlook": "Stabilitas nasional secara umum berada pada band Rendah-Sedang. Penguatan patroli siber dan dialog tokoh masyarakat direkomendasikan."
},
"generated_at": "2026-09-26T04:30:00Z",
"generated_from": {
"start": "2026-09-25T00:00:00Z",
"end": "2026-09-25T23:59:59Z"
}
}4. Hubungan dengan province_dashboard
Total angka nasional di national_dashboard dihitung sebagai agregat payung (umbrella rollup):
- Angka total event dan skor risiko merupakan konsolidasi dari 38 dokumen provinsi pada tanggal yang sama.
- Apabila terjadi anomali jeda data pada hari tertentu antara data nasional dan data provinsi, backend API melaporkan catatan ketidaksinkronan secara transparan pada metadata respons tanpa melakukan manipulasi angka tiruan (no synthetic patching).
5. Ringkasan Parameter Operasional Pipeline
| Parameter | Konfigurasi | Keterangan |
|---|---|---|
| Indeks Target | national_dashboard (Elasticsearch) | Klaster OLAP penopang metrik dan narasi nasional. |
| Worker Pemroses | nexa-aggregation | Menjalankan rollup komputasi harian setiap pukul 04:30 WIB. |
| Frekuensi | Batch Harian (Jendela 24 Jam) | Satu dokumen per hari untuk riwayat tren stabilitas nasional. |
| Endpoint API | GET /overview/intel-analysisGET /overview/national-risk | Memasok kartu KPI dan panel Analisa Intelijen Nasional. |
6. Spesifikasi Payload Request & Response Pipeline
Query agregasi yang dieksekusi nexa-aggregation ke province_dashboard untuk menjumlahkan metrik nasional:
POST /province_dashboard/_search
{
"size": 100,
"query": {
"term": { "target_date": "2026-09-26" }
},
"aggs": {
"total_national_events": { "sum": { "field": "total_event" } },
"avg_national_risk": { "avg": { "field": "threat_index" } },
"status_breakdown": { "terms": { "field": "readiness_status.keyword" } }
}
}pillar_intelligence
Alur sintesis penalaran LLM batch harian (03:00 WIB) untuk menghasilkan rekomendasi mitigasi pimpinan ke dalam indeks Elasticsearch pillar_intelligence.
intelligence_feed
Alur streaming kejadian intelijen real-time dari indeks Elasticsearch articles (diurutkan berdasarkan processed_at), pemetaan 5 tingkat keparahan risiko, skor kredibilitas sumber, dan penyajian live feed pada dashboard.