πΉ ΠΠ°ΠΊ Π² ΡΠ΅Π°Π»ΡΠ½ΠΎΠΌ Π²ΡΠ΅ΠΌΠ΅Π½ΠΈ ΠΎΡΡΠ»Π΅ΠΆΠΈΠ²Π°ΡΡ data latency (Π·Π°Π΄Π΅ΡΠΆΠΊΡ Π΄Π°Π½Π½ΡΡ
)? πΈ Data latency Π½ΡΠΆΠ½Π°, ΡΡΠΎΠ±Ρ Π·Π°ΠΌΠ΅ΡΠΈΡΡ, ΠΊΠΎΠ³Π΄Π° ΠΏΠΎΡΠΎΠΊΠΈ ΠΈΠ»ΠΈ ETL Π΄Π°ΡΡ ΡΡΡΠ°ΡΠ΅Π²ΡΠΈΠ΅ Π΄Π°Π½Π½ΡΠ΅ β Π±Π΅Π· ΡΡΠΎΠ³ΠΎ ΠΎΡΡΡΡΡ ΠΈ ML ΠΌΠΎΠ΄Π΅Π»ΠΈ Π±ΡΠ΄ΡΡ ΡΠ°Π±ΠΎΡΠ°ΡΡ Ρ Β«ΠΏΡΠΎΡΠ»ΠΎΠΉΒ» ΠΊΠ°ΡΡΠΈΠ½ΠΎΠΉ ΠΈ Π±ΠΈΠ·Π½Π΅Ρ ΠΏΡΠΈΠΌΠ΅Ρ Π½Π΅Π²Π΅ΡΠ½ΡΠ΅ ΡΠ΅ΡΠ΅Π½ΠΈΡ. πΈ ΠΠ°ΠΊ ΠΈΠ·ΠΌΠ΅ΡΡΡΡ: ΠΌΠ΅ΡΡΠΈΠΊΠ° lag = now() - max(event_time) ΠΏΠΎ ΠΈΡΡΠΎΡΠ½ΠΈΠΊΠ°ΠΌ/ΠΏΠ°ΡΡΠΈΡΠΈΡΠΌ; ΡΠΎΠ±ΠΈΡΠ°ΠΉΡΠ΅ Π΅Ρ ΡΠ΅Π³ΡΠ»ΡΡΠ½ΠΎ ΠΈ Ρ
ΡΠ°Π½ΠΈΡΠ΅ ΠΊΠ°ΠΊ time-series. SELECT source, now() - max(event_time) AS lag FROM events GROUP BY source; πΈ Monitoring: Π² dashboard ΡΡΡΠΎΠΈΡΠ΅ Π»ΠΈΠ½ΠΈΠΈ lag, ΡΡΠ°Π²ΠΈΡΠ΅ thresholds ΠΈ Π½Π°ΡΡΡΠ°ΠΈΠ²Π°Π΅ΡΠ΅ alerts (Telegram/Slack/pager) β ΡΡΠ°Π±Π°ΡΡΠ²Π°Π½ΠΈΠ΅ ΠΏΠΎ Π°Π±ΡΠΎΠ»ΡΡΠ½ΠΎΠΌΡ ΠΏΠΎΡΠΎΠ³Ρ ΠΈΠ»ΠΈ ΠΏΠΎ ΡΠ΅Π·ΠΊΠΎΠΌΡ ΡΠΎΡΡΡ. πΈ Π₯Π°ΠΊ: ΡΠΌΠΎΡΡΠΈΡΠ΅ Π½Π΅ ΡΠΎΠ»ΡΠΊΠΎ max, Π½ΠΎ 95-ΠΉ ΠΏΠ΅ΡΡΠ΅Π½ΡΠΈΠ»Ρ ΠΈ ΡΡΠ΅Π½Π΄ Π·Π° 5β15 ΠΌΠΈΠ½ΡΡ β ΡΡΠΎ ΡΠ½ΠΈΠΆΠ°Π΅Ρ Π»ΠΎΠΆΠ½ΡΠ΅ ΡΡΠ°Π±Π°ΡΡΠ²Π°Π½ΠΈΡ ΠΈ Π»ΠΎΠ²ΠΈΡ Π΄Π΅Π³ΡΠ°Π΄Π°ΡΠΈΡ ΡΠ°Π½ΡΡΠ΅. π ΠΠ°ΡΠ½ΠΈΡΠ΅ Ρ 1-ΠΌΠΈΠ½ΡΡΠ½ΠΎΠ³ΠΎ ΡΠ±ΠΎΡΠ° lag, ΠΏΡΠΎΡΡΠΎΠ³ΠΎ Π΄Π°ΡΠ±ΠΎΡΠ΄Π° ΠΈ Π±Π°Π·ΠΎΠ²ΡΡ
alerts; ΠΊΠΎΡΡΠ΅ΠΊΡΠΈΡΡΠΉΡΠ΅ ΠΏΠΎΡΠΎΠ³ΠΈ ΠΏΠΎ ΡΠ΅Π°Π»ΡΠ½ΡΠΌ ΠΈΠ½ΡΠΈΠ΄Π΅Π½ΡΠ°ΠΌ. #CODERIKK #DE #Junior β‘οΈ ΠΡ Π² Telegram - Π‘Π΅ΡΠΊΠ΅ - ΠΠ ΠΡΠ΄Ρ ΡΠ°Π΄ Π²Π°ΡΠ΅ΠΉ ΡΠ΅Π°ΠΊΡΠΈΠΈ Π·Π΄Π΅ΡΡβ¬οΈ
πΉ ΠΠΎΠ½ΠΈΡΠΎΡΠΈΠ½Π³ Π·Π°Π΄Π΅ΡΠΆΠ΅ΠΊ Π΄Π°Π½Π½ΡΡ β Π³ΠΎΠ½ΠΊΠ° Ρ ΡΠ°ΡΠ°ΠΌΠΈ
4Β ΠΌΠ°Ρ4Β ΠΌΠ°Ρ
~1 ΠΌΠΈΠ½