|
|
@@ -214,11 +214,11 @@ def write_batch_to_questdb(data_batch):
|
|
|
symbol = data['symbol']
|
|
|
binance_price = data['binance_price']
|
|
|
lighter_mark_price = data['lighter_mark_price']
|
|
|
- lighter_last_trade_price = data['lighter_last_trade_price']
|
|
|
+ lighter_price = data['lighter_price']
|
|
|
|
|
|
# 构建InfluxDB Line Protocol格式
|
|
|
# 格式: measurement,tag1=value1,tag2=value2 field1=value1,field2=value2 timestamp
|
|
|
- line = f"{QUESTDB_TABLE_PREFIX}_market_data,symbol={symbol} binance_price={binance_price},lighter_mark_price={lighter_mark_price},lighter_last_trade_price={lighter_last_trade_price}"
|
|
|
+ line = f"{QUESTDB_TABLE_PREFIX}_market_data,symbol={symbol} binance_price={binance_price},lighter_mark_price={lighter_mark_price},lighter_price={lighter_price}"
|
|
|
lines.append(line)
|
|
|
|
|
|
# 将所有行合并为一个字符串,用换行符分隔
|
|
|
@@ -276,7 +276,7 @@ def process_data(lighter_data, binance_data):
|
|
|
'symbol': base_symbol,
|
|
|
'binance_price': float(binance_price),
|
|
|
'lighter_mark_price': lighter_stats.get('mark_price'),
|
|
|
- 'lighter_last_trade_price': lighter_stats.get('last_trade_price'),
|
|
|
+ 'lighter_price': lighter_stats.get('last_trade_price'),
|
|
|
'timestamp': int(time.time() * 1000) # 毫秒时间戳
|
|
|
}
|
|
|
|