# Cassandra时序数据写入脚本

CASSANDRA_HOST=”192.168.1.101″
KEYSPACE=”fgedu_timeseries”
LOG_FILE=”/cassandra/logs/timeseries_write_$(date +%Y%m%d).log”

log() {
echo “[$(date ‘+%Y-%m-%d %H:%M:%S’)] $1” | tee -a ${LOG_FILE}
}

write_metrics() {
log “写入监控指标数据…”

METRIC_NAME=”cpu_usage”
BUCKET_TIME=$(date -d “$(date +%Y-%m-%d) $(date +%H):00:00” +%s)000
COLLECT_TIME=$(date +%s)000
METRIC_VALUE=$(awk -v min=10 -v max=90 ‘BEGIN{srand(); print min+rand()*(max-min)}’)

cqlsh ${CASSANDRA_HOST} -e “
INSERT INTO ${KEYSPACE}.fgedu_metrics
(metric_name, bucket_time, collect_time, metric_value, tags)
VALUES (‘${METRIC_NAME}’, ${BUCKET_TIME}, ${COLLECT_TIME}, ${METRIC_VALUE}, {‘host’: ‘server01’, ‘region’: ‘beijing’})
USING TTL 2592000;
” 2>&1 | tee -a ${LOG_FILE}
}

write_logs() {
log “写入日志数据…”

LOG_SOURCE=”app-server”
LOG_DATE=$(date +%Y-%m-%d)
LOG_TIME=$(date +%s)000
LOG_LEVEL=”INFO”
LOG_MESSAGE=”Application started successfully”

cqlsh ${CASSANDRA_HOST} -e “
INSERT INTO ${KEYSPACE}.fgedu_logs
(log_source, log_date, log_time, log_level, log_message, log_metadata)
VALUES (‘${LOG_SOURCE}’, ‘${LOG_DATE}’, ${LOG_TIME}, ‘${LOG_LEVEL}’, ‘${LOG_MESSAGE}’, {‘app’: ‘webapp’, ‘version’: ‘1.0.0’})
USING TTL 7776000;
” 2>&1 | tee -a ${LOG_FILE}
}

write_transactions() {
log “写入交易数据…”

ACCOUNT_ID=”ACC123456789″
TRANS_DATE=$(date +%Y-%m-%d)
TRANS_TIME=$(date +%s)000
TRANS_ID=$(uuidgen)
TRANS_TYPE=”DEPOSIT”
AMOUNT=”1000.00″
BALANCE=”15000.00″
DESCRIPTION=”Monthly salary deposit”

cqlsh ${CASSANDRA_HOST} -e “
INSERT INTO ${KEYSPACE}.fgedu_transactions
(account_id, transaction_date, transaction_time, transaction_id, transaction_type, amount, balance, description)
VALUES (‘${ACCOUNT_ID}’, ‘${TRANS_DATE}’, ${TRANS_TIME}, ${TRANS_ID}, ‘${TRANS_TYPE}’, ${AMOUNT}, ${BALANCE}, ‘${DESCRIPTION}’)
USING TTL 220752000;
” 2>&1 | tee -a ${LOG_FILE}
}

main() {
log “=== 开始时序数据写入 ===”

write_metrics
write_logs
write_transactions

log “=== 时序数据写入完成 ===”
}

main