tour 13 live watching

import%20marimo%0A%0A__generated_with%20%3D%20%220.18.4%22%0Aapp%20%3D%20marimo.App(width%3D%22medium%22)%0A%0A%0A%40app.cell%0Adef%20_()%3A%0A%20%20%20%20import%20marimo%20as%20mo%0A%20%20%20%20return%20(mo%2C)%0A%0A%0A%40app.cell%0Adef%20_(mo)%3A%0A%20%20%20%20mo.md(r%22%22%22%0A%20%20%20%20%23%20Tour%2013%3A%20Live%20Log%20Watching%20-%20Real-Time%20Analysis%0A%0A%20%20%20%20**Watch%20logs%20as%20they%20happen.%20Detect%20anomalies%20in%20real-time.**%0A%0A%20%20%20%20In%20production%2C%20logs%20are%20constantly%20flowing.%20You%20need%20to%3A%0A%20%20%20%20-%20Tail%20logs%20as%20they're%20written%0A%20%20%20%20-%20Detect%20error%20spikes%20immediately%0A%20%20%20%20-%20Alert%20on%20anomalies%0A%0A%20%20%20%20Logler's%20%60LogReader%60%20supports%20live%20tailing%20with%20%60follow%3DTrue%60.%0A%0A%20%20%20%20**In%20this%20tour%3A**%0A%20%20%20%201.%20Start%20a%20background%20log%20writer%20(simulates%20a%20running%20service)%0A%20%20%20%202.%20Watch%20logs%20stream%20in%20real-time%0A%20%20%20%203.%20Detect%20and%20alert%20on%20errors%0A%20%20%20%204.%20Count%20patterns%20as%20they%20arrive%0A%20%20%20%20%22%22%22)%0A%20%20%20%20return%0A%0A%0A%40app.cell%0Adef%20_()%3A%0A%20%20%20%20import%20json%0A%20%20%20%20import%20tempfile%0A%20%20%20%20import%20threading%0A%20%20%20%20import%20time%0A%20%20%20%20from%20pathlib%20import%20Path%0A%20%20%20%20from%20datetime%20import%20datetime%2C%20timezone%0A%0A%20%20%20%20%23%20Create%20temp%20directory%0A%20%20%20%20temp_dir%20%3D%20tempfile.mkdtemp()%0A%20%20%20%20live_log%20%3D%20Path(temp_dir)%20%2F%20%22live_service.log%22%0A%0A%20%20%20%20%23%20Touch%20the%20file%0A%20%20%20%20live_log.touch()%0A%0A%20%20%20%20print(f%22Live%20log%20file%3A%20%7Blive_log%7D%22)%0A%20%20%20%20return%20datetime%2C%20json%2C%20live_log%2C%20temp_dir%2C%20threading%2C%20time%2C%20timezone%0A%0A%0A%40app.cell%0Adef%20_(mo)%3A%0A%20%20%20%20mo.md(r%22%22%22%0A%20%20%20%20%23%23%201.%20The%20Log%20Writer%20(Simulated%20Service)%0A%0A%20%20%20%20This%20function%20simulates%20a%20running%20service%20writing%20logs.%0A%20%20%20%20-%20Normal%20INFO%20logs%20most%20of%20the%20time%0A%20%20%20%20-%20Occasional%20WARN%20logs%0A%20%20%20%20-%20Periodic%20ERROR%20bursts%20(simulating%20incidents)%0A%20%20%20%20%22%22%22)%0A%20%20%20%20return%0A%0A%0A%40app.cell%0Adef%20_(datetime%2C%20timezone)%3A%0A%20%20%20%20def%20make_log_entry(i%2C%20level%3D%22INFO%22)%3A%0A%20%20%20%20%20%20%20%20messages%20%3D%20%7B%0A%20%20%20%20%20%20%20%20%20%20%20%20%22INFO%22%3A%20%5B%0A%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%22Request%20processed%20successfully%22%2C%0A%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%22User%20session%20started%22%2C%0A%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%22Cache%20hit%20for%20key%22%2C%0A%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%22Database%20query%20completed%22%2C%0A%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%22API%20response%20sent%22%2C%0A%20%20%20%20%20%20%20%20%20%20%20%20%5D%2C%0A%20%20%20%20%20%20%20%20%20%20%20%20%22WARN%22%3A%20%5B%0A%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%22High%20memory%20usage%20detected%22%2C%0A%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%22Slow%20query%20warning%3A%20%3E100ms%22%2C%0A%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%22Rate%20limit%20approaching%22%2C%0A%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%22Connection%20pool%20running%20low%22%2C%0A%20%20%20%20%20%20%20%20%20%20%20%20%5D%2C%0A%20%20%20%20%20%20%20%20%20%20%20%20%22ERROR%22%3A%20%5B%0A%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%22Database%20connection%20failed%22%2C%0A%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%22Timeout%20waiting%20for%20response%22%2C%0A%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%22Authentication%20failed%22%2C%0A%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%22Service%20unavailable%22%2C%0A%20%20%20%20%20%20%20%20%20%20%20%20%5D%2C%0A%20%20%20%20%20%20%20%20%7D%0A%0A%20%20%20%20%20%20%20%20msg%20%3D%20messages%5Blevel%5D%5Bi%20%25%20len(messages%5Blevel%5D)%5D%0A%0A%20%20%20%20%20%20%20%20return%20%7B%0A%20%20%20%20%20%20%20%20%20%20%20%20%22timestamp%22%3A%20datetime.now(timezone.utc).isoformat()%2C%0A%20%20%20%20%20%20%20%20%20%20%20%20%22level%22%3A%20level%2C%0A%20%20%20%20%20%20%20%20%20%20%20%20%22message%22%3A%20msg%2C%0A%20%20%20%20%20%20%20%20%20%20%20%20%22request_id%22%3A%20f%22req-%7Bi%3A05d%7D%22%2C%0A%20%20%20%20%20%20%20%20%20%20%20%20%22service%22%3A%20%22live-demo-service%22%2C%0A%20%20%20%20%20%20%20%20%7D%0A%0A%20%20%20%20print(%22Log%20entry%20generator%20ready%22)%0A%20%20%20%20return%20(make_log_entry%2C)%0A%0A%0A%40app.cell%0Adef%20_(json%2C%20make_log_entry%2C%20time)%3A%0A%20%20%20%20def%20log_writer(path%2C%20stop_event%2C%20total_written)%3A%0A%20%20%20%20%20%20%20%20%22%22%22Background%20writer%20that%20simulates%20a%20live%20service.%22%22%22%0A%20%20%20%20%20%20%20%20with%20open(path%2C%20%22a%22)%20as%20f%3A%0A%20%20%20%20%20%20%20%20%20%20%20%20i%20%3D%200%0A%20%20%20%20%20%20%20%20%20%20%20%20while%20not%20stop_event.is_set()%20and%20i%20%3C%2050%3A%20%20%23%20Write%20up%20to%2050%20logs%0A%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%23%20Determine%20log%20level%20based%20on%20pattern%0A%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20if%20i%20%3E%3D%2030%20and%20i%20%3C%2040%3A%0A%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%23%20Error%20burst%20from%20log%2030-39%0A%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20level%20%3D%20%22ERROR%22%0A%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20elif%20i%20%25%2010%20%3D%3D%200%3A%0A%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20level%20%3D%20%22WARN%22%0A%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20else%3A%0A%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20level%20%3D%20%22INFO%22%0A%0A%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20entry%20%3D%20make_log_entry(i%2C%20level)%0A%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20f.write(json.dumps(entry)%20%2B%20%22%5Cn%22)%0A%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20f.flush()%0A%0A%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20total_written%5B0%5D%20%3D%20i%20%2B%201%0A%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20i%20%2B%3D%201%0A%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20time.sleep(0.15)%20%20%23%20150ms%20between%20logs%0A%0A%20%20%20%20print(%22Log%20writer%20function%20defined%22)%0A%20%20%20%20return%20(log_writer%2C)%0A%0A%0A%40app.cell%0Adef%20_(mo)%3A%0A%20%20%20%20mo.md(r%22%22%22%0A%20%20%20%20%23%23%202.%20Start%20the%20Background%20Writer%0A%0A%20%20%20%20We'll%20start%20a%20background%20thread%20that%20writes%20logs%20every%20150ms.%0A%20%20%20%20This%20simulates%20a%20real%20service%20running%20in%20production.%0A%20%20%20%20%22%22%22)%0A%20%20%20%20return%0A%0A%0A%40app.cell%0Adef%20_(live_log%2C%20log_writer%2C%20threading)%3A%0A%20%20%20%20%23%20Control%20objects%0A%20%20%20%20stop_event%20%3D%20threading.Event()%0A%20%20%20%20total_written%20%3D%20%5B0%5D%0A%0A%20%20%20%20%23%20Start%20the%20writer%20thread%0A%20%20%20%20writer_thread%20%3D%20threading.Thread(target%3Dlog_writer%2C%20args%3D(live_log%2C%20stop_event%2C%20total_written))%0A%20%20%20%20writer_thread.start()%0A%0A%20%20%20%20print(%22Background%20log%20writer%20started!%22)%0A%20%20%20%20print(%22Logs%20are%20being%20written%20every%20150ms...%22)%0A%20%20%20%20return%20stop_event%2C%20total_written%2C%20writer_thread%0A%0A%0A%40app.cell%0Adef%20_(mo)%3A%0A%20%20%20%20mo.md(r%22%22%22%0A%20%20%20%20%23%23%203.%20Watch%20Logs%20in%20Real-Time%0A%0A%20%20%20%20Now%20we%20use%20%60LogReader.tail(follow%3DTrue)%60%20to%20stream%20logs%20as%20they%20arrive.%0A%0A%20%20%20%20**Watch%20for%3A**%0A%20%20%20%20-%20Normal%20INFO%20logs%0A%20%20%20%20-%20WARN%20indicators%0A%20%20%20%20-%20ERROR%20bursts%20(the%20incident%20simulation!)%0A%20%20%20%20%22%22%22)%0A%20%20%20%20return%0A%0A%0A%40app.cell%0Adef%20_(json%2C%20live_log%2C%20stop_event%2C%20time%2C%20total_written)%3A%0A%20%20%20%20from%20logler%20import%20LogReader%0A%0A%20%20%20%20reader%20%3D%20LogReader(str(live_log))%0A%0A%20%20%20%20%23%20Counters%20for%20real-time%20stats%0A%20%20%20%20stats%20%3D%20%7B%22INFO%22%3A%200%2C%20%22WARN%22%3A%200%2C%20%22ERROR%22%3A%200%7D%0A%20%20%20%20recent_errors%20%3D%20%5B%5D%0A%0A%20%20%20%20print(%22%3D%22%20*%2060)%0A%20%20%20%20print(%22LIVE%20LOG%20STREAM%22)%0A%20%20%20%20print(%22%3D%22%20*%2060)%0A%0A%20%20%20%20%23%20Read%20with%20follow%20mode%20(limited%20iterations%20for%20demo)%0A%20%20%20%20lines_read%20%3D%200%0A%20%20%20%20max_lines%20%3D%2050%0A%0A%20%20%20%20for%20line%20in%20reader.tail(num_lines%3D0%2C%20follow%3DTrue)%3A%0A%20%20%20%20%20%20%20%20if%20lines_read%20%3E%3D%20max_lines%3A%0A%20%20%20%20%20%20%20%20%20%20%20%20break%0A%0A%20%20%20%20%20%20%20%20try%3A%0A%20%20%20%20%20%20%20%20%20%20%20%20_entry%20%3D%20json.loads(line)%0A%20%20%20%20%20%20%20%20%20%20%20%20_level%20%3D%20_entry.get(%22level%22%2C%20%22INFO%22)%0A%20%20%20%20%20%20%20%20%20%20%20%20_msg%20%3D%20_entry.get(%22message%22%2C%20%22%22)%5B%3A50%5D%0A%0A%20%20%20%20%20%20%20%20%20%20%20%20stats%5B_level%5D%20%3D%20stats.get(_level%2C%200)%20%2B%201%0A%0A%20%20%20%20%20%20%20%20%20%20%20%20%23%20Visual%20indicators%20(consistent%2010-char%20prefix%20for%20alignment)%0A%20%20%20%20%20%20%20%20%20%20%20%20if%20_level%20%3D%3D%20%22ERROR%22%3A%0A%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20print(f%22%F0%9F%9A%A8%20ERROR%20%20%7C%20%7B_msg%7D%22)%0A%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20recent_errors.append(_entry)%0A%20%20%20%20%20%20%20%20%20%20%20%20elif%20_level%20%3D%3D%20%22WARN%22%3A%0A%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20print(f%22%E2%9A%A0%EF%B8%8F%20WARN%20%20%20%7C%20%7B_msg%7D%22)%0A%20%20%20%20%20%20%20%20%20%20%20%20else%3A%0A%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20print(f%22%20%20%20INFO%20%20%20%7C%20%7B_msg%7D%22)%0A%0A%20%20%20%20%20%20%20%20%20%20%20%20lines_read%20%2B%3D%201%0A%0A%20%20%20%20%20%20%20%20except%20json.JSONDecodeError%3A%0A%20%20%20%20%20%20%20%20%20%20%20%20continue%0A%0A%20%20%20%20%20%20%20%20%23%20Brief%20pause%20to%20let%20more%20logs%20arrive%0A%20%20%20%20%20%20%20%20time.sleep(0.05)%0A%0A%20%20%20%20%23%20Stop%20the%20writer%0A%20%20%20%20stop_event.set()%0A%0A%20%20%20%20print(%22%5Cn%22%20%2B%20%22%3D%22%20*%2060)%0A%20%20%20%20print(f%22Stream%20ended.%20Total%20logs%20written%3A%20%7Btotal_written%5B0%5D%7D%22)%0A%20%20%20%20return%20recent_errors%2C%20stats%0A%0A%0A%40app.cell%0Adef%20_(mo)%3A%0A%20%20%20%20mo.md(r%22%22%22%0A%20%20%20%20%23%23%204.%20Real-Time%20Statistics%0A%0A%20%20%20%20As%20logs%20stream%20in%2C%20we%20tracked%20statistics.%0A%20%20%20%20In%20production%2C%20you'd%20use%20this%20for%20dashboards%20and%20alerts.%0A%20%20%20%20%22%22%22)%0A%20%20%20%20return%0A%0A%0A%40app.cell%0Adef%20_(recent_errors%2C%20stats)%3A%0A%20%20%20%20print(%22%3D%22%20*%2060)%0A%20%20%20%20print(%22REAL-TIME%20STATISTICS%22)%0A%20%20%20%20print(%22%3D%22%20*%2060)%0A%0A%20%20%20%20print(%22%5CnLog%20Level%20Distribution%3A%22)%0A%20%20%20%20total%20%3D%20sum(stats.values())%0A%20%20%20%20for%20_level%2C%20_count%20in%20stats.items()%3A%0A%20%20%20%20%20%20%20%20_pct%20%3D%20(_count%20%2F%20total%20*%20100)%20if%20total%20%3E%200%20else%200%0A%20%20%20%20%20%20%20%20_bar%20%3D%20%22%E2%96%88%22%20*%20int(_pct%20%2F%205)%0A%20%20%20%20%20%20%20%20print(f%22%20%20%7B_level%3A5%7D%3A%20%7B_count%3A3%7D%20(%7B_pct%3A5.1f%7D%25)%20%7B_bar%7D%22)%0A%0A%20%20%20%20print(f%22%5CnTotal%20logs%20processed%3A%20%7Btotal%7D%22)%0A%0A%20%20%20%20if%20recent_errors%3A%0A%20%20%20%20%20%20%20%20error_rate%20%3D%20len(recent_errors)%20%2F%20total%20*%20100%0A%20%20%20%20%20%20%20%20print(f%22%5Cn%E2%9A%A0%EF%B8%8F%20%20Error%20rate%3A%20%7Berror_rate%3A.1f%7D%25%22)%0A%0A%20%20%20%20%20%20%20%20if%20error_rate%20%3E%2010%3A%0A%20%20%20%20%20%20%20%20%20%20%20%20print(%22%F0%9F%9A%A8%20ALERT%3A%20Error%20rate%20exceeded%2010%25%20threshold!%22)%0A%0A%20%20%20%20%20%20%20%20print(f%22%5CnRecent%20errors%20(%7Blen(recent_errors)%7D)%3A%22)%0A%20%20%20%20%20%20%20%20for%20_err%20in%20recent_errors%5B-5%3A%5D%3A%0A%20%20%20%20%20%20%20%20%20%20%20%20print(f%22%20%20-%20%7B_err%5B'message'%5D%7D%22)%0A%20%20%20%20return%0A%0A%0A%40app.cell%0Adef%20_(mo)%3A%0A%20%20%20%20mo.md(r%22%22%22%0A%20%20%20%20%23%23%205.%20Anomaly%20Detection%20Pattern%0A%0A%20%20%20%20In%20real%20production%20use%2C%20you'd%20implement%20patterns%20like%3A%0A%0A%20%20%20%20%60%60%60python%0A%20%20%20%20%23%20Sliding%20window%20error%20detection%0A%20%20%20%20error_window%20%3D%20%5B%5D%0A%20%20%20%20WINDOW_SIZE%20%3D%2060%20%20%23%20seconds%0A%20%20%20%20ERROR_THRESHOLD%20%3D%2010%20%20%23%20errors%20per%20minute%0A%0A%20%20%20%20for%20line%20in%20reader.tail(follow%3DTrue)%3A%0A%20%20%20%20%20%20%20%20entry%20%3D%20json.loads(line)%0A%20%20%20%20%20%20%20%20now%20%3D%20datetime.now()%0A%0A%20%20%20%20%20%20%20%20if%20entry%5B'level'%5D%20%3D%3D%20'ERROR'%3A%0A%20%20%20%20%20%20%20%20%20%20%20%20error_window.append(now)%0A%0A%20%20%20%20%20%20%20%20%23%20Prune%20old%20entries%0A%20%20%20%20%20%20%20%20error_window%20%3D%20%5Bt%20for%20t%20in%20error_window%0A%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20%20if%20(now%20-%20t).seconds%20%3C%20WINDOW_SIZE%5D%0A%0A%20%20%20%20%20%20%20%20%23%20Check%20threshold%0A%20%20%20%20%20%20%20%20if%20len(error_window)%20%3E%20ERROR_THRESHOLD%3A%0A%20%20%20%20%20%20%20%20%20%20%20%20send_alert(%22Error%20spike%20detected!%22)%0A%20%20%20%20%20%20%20%20%20%20%20%20error_window.clear()%0A%20%20%20%20%60%60%60%0A%20%20%20%20%22%22%22)%0A%20%20%20%20return%0A%0A%0A%40app.cell%0Adef%20_(mo)%3A%0A%20%20%20%20mo.md(r%22%22%22%0A%20%20%20%20%23%23%20Summary%0A%0A%20%20%20%20You've%20learned%20real-time%20log%20watching%3A%0A%0A%20%20%20%20-%20**%60LogReader.tail(follow%3DTrue)%60**%20-%20Stream%20logs%20as%20they're%20written%0A%20%20%20%20-%20**Real-time%20counting**%20-%20Track%20stats%20as%20logs%20flow%0A%20%20%20%20-%20**Anomaly%20detection**%20-%20Alert%20on%20error%20spikes%0A%0A%20%20%20%20**Production%20use%20cases%3A**%0A%20%20%20%20-%20Live%20dashboards%0A%20%20%20%20-%20PagerDuty%2FSlack%20alerts%0A%20%20%20%20-%20Auto-scaling%20triggers%0A%20%20%20%20-%20Security%20monitoring%0A%0A%20%20%20%20**Next%20Steps%3A**%0A%20%20%20%20-%20**Tour%2014**%3A%20Performance%20at%20scale%20(10%2C000%2B%20entries)%0A%20%20%20%20%22%22%22)%0A%20%20%20%20return%0A%0A%0A%40app.cell%0Adef%20_(stop_event%2C%20temp_dir%2C%20writer_thread)%3A%0A%20%20%20%20import%20shutil%0A%0A%20%20%20%20%23%20Make%20sure%20writer%20is%20stopped%0A%20%20%20%20stop_event.set()%0A%20%20%20%20writer_thread.join(timeout%3D2)%0A%0A%20%20%20%20shutil.rmtree(temp_dir%2C%20ignore_errors%3DTrue)%0A%20%20%20%20print(%22Cleaned%20up%20temp%20files%22)%0A%20%20%20%20return%0A%0A%0A%40app.cell%0Adef%20_()%3A%0A%20%20%20%20return%0A%0A%0Aif%20__name__%20%3D%3D%20%22__main__%22%3A%0A%20%20%20%20app.run()%0A