在并發過程中，每個viewer會產生一個對應的日志文件，日志文件名為：

viewer_channel_index_20250626_030943_145.log

viewer端日志比master端日志文件數量多，比例大概是5:1，有1個master就會有5個viewer，每個viewer對應一個日志文件。
我要統計的是從啟動viewer到出第一幀視頻和第一幀音頻過程中各節點的時間，大概包括：

1. viewer端啟動時間點；
2. 獲取ICE配置時間；
3. 連接信令服務時間；
4. tls握手時間；
5. 從offer發送到收到answer時間；
6. dtls初始化完成時間；
7. P2P打洞時間；
8. 計算收到第一幀音頻用時；
9. 計算收到第一幀視頻用時。

代碼實現

#!/bin/bashlog_dir="./log/viewer"
output_csv="viewer_log_analysis.csv"# 內網IP
# ip_addr=$(hostname -I | awk '{print $1}')# 獲取公網IP
TOKEN=$(curl -X PUT "http://169.254.169.254/latest/api/token" -H "X-aws-ec2-metadata-token-ttl-seconds: 21600" -s)
PUBLIC_IP=$(curl -s -H "X-aws-ec2-metadata-token: $TOKEN" http://169.254.169.254/latest/meta-data/public-ipv4)# 輸出 CSV 表頭
echo "host,channel,index,start_time,get_ice_config_signaling_call,connect_signaling_client,tls_handshake_time,offer_sent_to_answer_received_time,dtls_initialization_completion,ice_hole_punching_time,first_audio_time,audio_latency_ms,first_video_time,video_latency_ms,pull_success,stable_audio,stable_video" > "$output_csv"# 判斷幀時間是否穩定（±20%）
is_stable() {local expected_ms=$1shiftlocal -a times=("$@")local lower=$((expected_ms * 8 / 10))local upper=$((expected_ms * 12 / 10))for ((i = 1; i < ${#times[@]}; i++)); dolocal diff=$((times[i] - times[i-1]))if (( diff < lower || diff > upper )); thenreturn 1fidonereturn 0
}# 主分析流程
for log_file in "$log_dir"/viewer_*.log; dofilename=$(basename "$log_file")channel=$(echo "$filename" | cut -d'_' -f2)index=$(echo "$filename" | cut -d'_' -f3)# 用 awk 處理大文件只讀一次，提取時間戳mapfile -t results < <(awk 'function to_millis(t) {# 時間格式 2025-06-12 07:19:20.039split(t, a, /[- :\.]/);# mktime參數格式：YYYY MM DD HH MM SSsec = mktime(a[1] " " a[2] " " a[3] " " a[4] " " a[5] " " a[6]);ms = a[7];return sec * 1000 + ms;}BEGIN {audio_count = 0; video_count = 0;}# 記錄起始時間和首幀時間（這里存原始時間字符串）/Initializing WebRTC library/ && !start {start = $1 " " $2;start_ms = to_millis(start);}/Get ICE config signaling call/ && !ice_config {match($0, /Time taken: ([0-9]+)/, m);if (m[1]) ice_config = m[1];}/Connect signaling client/ && !signaling_connect {match($0, /Time taken: ([0-9]+)/, m);if (m[1]) signaling_connect = m[1];}/TLS handshake time/ && !tls_handshake {match($0, /Time taken: ([0-9]+)/, m);if (m[1]) tls_handshake = m[1];}/Offer Sent to Answer Received time/ && !sdp_answer_delay {match($0, /Time taken: ([0-9]+)/, m);if (m[1]) sdp_answer_delay = m[1];}/DTLS initialization completion/ && !dtls_init {match($0, /Time taken: ([0-9]+)/, m);if (m[1]) dtls_init = m[1];}/ICE Hole Punching Time/ && !ice_punching {match($0, /Time taken: ([0-9]+)/, m);if (m[1]) ice_punching = m[1];}/Audio Frame received/ && $0 !~ /Size: 0/ {if (!audio_first) {audio_first = $1 " " $2;audio_first_ms = to_millis(audio_first);}if (audio_count < 30) {audio_ms[audio_count++] = to_millis($1 " " $2);}}/Video Frame received/ && $0 !~ /Size: 0/ {if (!video_first) {video_first = $1 " " $2;video_first_ms = to_millis(video_first);}if (video_count < 30) {video_ms[video_count++] = to_millis($1 " " $2);}}END {print start;print ice_config + 0;print signaling_connect + 0;print tls_handshake + 0;print sdp_answer_delay + 0;print dtls_init + 0;print ice_punching + 0;print audio_first;print video_first;print start_ms;print audio_first_ms;print video_first_ms;for (i = 0; i < audio_count; i++) print "A " audio_ms[i];for (i = 0; i < video_count; i++) print "V " video_ms[i];}'