XuJiacheng
2f8857f98e
- 新增 G5 数据库连接配置与可关闭的写入开关 - 在现有 legacy/G4 写入成功路径后，追加独立的 G5 写入流程 - G5 使用与 G4 相同的数据结构映射，但不写入 guid，由数据库自生成 int4 guid - room_status 新增 G5 独立 upsert 写入路径，并保留旧表与 G5 表的独立开关 - 新增 G5 写入统计与启动摘要输出 - 更新 StatsCounters 和 StatsReporter 以支持 G5 统计 - 增加测试覆盖，确保 G5 写入逻辑与 room_status 的独立执行 - 新增 G5 相关数据库表结构 SQL 文件
104 lines
2.6 KiB
Plaintext
104 lines
2.6 KiB
Plaintext
# =========================
|
||
# 应用基础配置
|
||
# =========================
|
||
NODE_ENV=production
|
||
PORT=3000
|
||
|
||
# 日志级别：debug | info | warn | error
|
||
LOG_LEVEL=info
|
||
LOG_FORMAT=json
|
||
|
||
# =========================
|
||
# Kafka 配置
|
||
# =========================
|
||
# 多个 broker 用英文逗号分隔
|
||
KAFKA_BROKERS=localhost:9092
|
||
KAFKA_CLIENT_ID=bls-heartbeat
|
||
KAFKA_GROUP_ID=bls-heartbeat-consumer
|
||
|
||
# 推荐使用 KAFKA_TOPICS；多个 topic 用英文逗号分隔
|
||
KAFKA_TOPICS=blwlog4Nodejs-rcu-heartbeat-topic
|
||
|
||
# 兼容旧写法；如已使用 KAFKA_TOPICS，可不填写
|
||
# KAFKA_TOPIC=blwlog4Nodejs-rcu-heartbeat-topic
|
||
|
||
# latest / earliest
|
||
KAFKA_FROM_OFFSET=latest
|
||
KAFKA_CONSUMER_INSTANCES=6
|
||
KAFKA_AUTO_COMMIT=true
|
||
KAFKA_AUTO_COMMIT_INTERVAL_MS=5000
|
||
KAFKA_RETRY_ATTEMPTS=0
|
||
KAFKA_RETRY_DELAY=1000
|
||
KAFKA_MAX_IN_FLIGHT_MESSAGES=200
|
||
KAFKA_FETCH_MAX_BYTES=10485760
|
||
KAFKA_FETCH_MIN_BYTES=1
|
||
KAFKA_FETCH_MAX_WAIT_MS=100
|
||
|
||
# SASL/SSL 按实际环境开启
|
||
KAFKA_SASL_ENABLED=false
|
||
KAFKA_SASL_MECHANISM=plain
|
||
KAFKA_SASL_USERNAME=
|
||
KAFKA_SASL_PASSWORD=
|
||
KAFKA_SSL_ENABLED=false
|
||
|
||
# =========================
|
||
# PostgreSQL 配置
|
||
# =========================
|
||
POSTGRES_HOST=127.0.0.1
|
||
POSTGRES_PORT=5432
|
||
POSTGRES_DATABASE=log_platform
|
||
POSTGRES_USER=log_admin
|
||
POSTGRES_PASSWORD=your_password
|
||
POSTGRES_IDLE_TIMEOUT_MS=30000
|
||
|
||
# 可选：兼容标准 PG 环境变量；留空则优先使用上面的 POSTGRES_*
|
||
# PGHOST=
|
||
# PGPORT=
|
||
# PGTARGETDB=
|
||
# PGUSER=
|
||
# PGPASSWORD=
|
||
|
||
# 数据库失败重试
|
||
DB_RETRY_ATTEMPTS=3
|
||
DB_RETRY_DELAY=1000
|
||
|
||
# 双写开关
|
||
# 旧明细表：heartbeat.heartbeat_events
|
||
DB_LEGACY_HEARTBEAT_ENABLED=true
|
||
# 新热表：heartbeat.heartbeat_events_g4_hot
|
||
DB_G4_HOT_HEARTBEAT_ENABLED=false
|
||
# G5 临时热表：heartbeat.heartbeat_events_g5
|
||
DB_G5_HEARTBEAT_ENABLED=false
|
||
# room_status 写入开关
|
||
DB_ROOM_STATUS_ENABLED=true
|
||
# G5 room_status 写入开关
|
||
DB_G5_ROOM_STATUS_ENABLED=false
|
||
|
||
# 如无特殊需要，保持默认表名即可
|
||
DB_LEGACY_TABLE=heartbeat.heartbeat_events
|
||
DB_G4_HOT_TABLE=heartbeat.heartbeat_events_g4_hot
|
||
DB_G5_TABLE=heartbeat.heartbeat_events_g5
|
||
DB_ROOM_STATUS_TABLE=room_status.room_status_moment
|
||
DB_G5_ROOM_STATUS_TABLE=room_status.room_status_moment_g5
|
||
|
||
# =========================
|
||
# Redis 配置
|
||
# =========================
|
||
REDIS_ENABLED=true
|
||
REDIS_HOST=10.8.8.109
|
||
REDIS_PORT=6379
|
||
REDIS_PASSWORD=
|
||
REDIS_DB=15
|
||
|
||
# 若提供 REDIS_URL，则业务侧可优先使用统一连接串
|
||
REDIS_URL=
|
||
REDIS_CONNECT_TIMEOUT_MS=5000
|
||
REDIS_PROJECT_NAME=BLS主机心跳日志
|
||
REDIS_HEARTBEAT_INTERVAL_MS=3000
|
||
REDIS_API_BASE_URL=http://127.0.0.1:3000
|
||
|
||
# =========================
|
||
# 批处理配置
|
||
# =========================
|
||
PROCESSOR_BATCH_SIZE=100
|
||
PROCESSOR_BATCH_TIMEOUT=5000 |