From 28f2daeb05f18caa874b89f15bf45be36208fb4e Mon Sep 17 00:00:00 2001 From: cryptooda Date: Tue, 28 Oct 2025 19:06:33 +0700 Subject: [PATCH] Update the keep for influx request --- .../InfluxDb/AgentBalanceRepository.cs | 4 ++-- .../InfluxDb/CandleRepository.cs | 8 ++++---- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/src/Managing.Infrastructure.Database/InfluxDb/AgentBalanceRepository.cs b/src/Managing.Infrastructure.Database/InfluxDb/AgentBalanceRepository.cs index e329ae8d..5df77a2b 100644 --- a/src/Managing.Infrastructure.Database/InfluxDb/AgentBalanceRepository.cs +++ b/src/Managing.Infrastructure.Database/InfluxDb/AgentBalanceRepository.cs @@ -88,8 +88,8 @@ public class AgentBalanceRepository : IAgentBalanceRepository $") " + $"|> filter(fn: (r) => r[\"user_id\"] == \"{userId}\") " + $"|> aggregateWindow(every: {samplingInterval}, fn: last, createEmpty: false) " + - $"|> drop(columns: [\"_start\", \"_stop\"])" + - $"|> pivot(rowKey: [\"_time\"], columnKey: [\"_field\"], valueColumn: \"_value\")"; + $"|> pivot(rowKey: [\"_time\"], columnKey: [\"_field\"], valueColumn: \"_value\")" + + $"|> keep(columns: [\"_time\", \"user_id\", \"total_balance_value\", \"usdc_wallet_value\", \"usdc_in_positions_value\", \"bots_allocation_usd_value\", \"pnl\"])"; var result = await query.QueryAsync(flux, _influxDbRepository.Organization); diff --git a/src/Managing.Infrastructure.Database/InfluxDb/CandleRepository.cs b/src/Managing.Infrastructure.Database/InfluxDb/CandleRepository.cs index ed95ec12..6d7f70a3 100644 --- a/src/Managing.Infrastructure.Database/InfluxDb/CandleRepository.cs +++ b/src/Managing.Infrastructure.Database/InfluxDb/CandleRepository.cs @@ -37,8 +37,8 @@ public class CandleRepository : ICandleRepository $"|> filter(fn: (r) => r[\"exchange\"] == \"{exchange}\")" + $"|> filter(fn: (r) => r[\"ticker\"] == \"{ticker}\")" + $"|> filter(fn: (r) => r[\"timeframe\"] == \"{timeframe}\")" + - $"|> drop(columns: [\"_start\", \"_stop\"])" + - $"|> pivot(rowKey:[\"_time\"], columnKey: [\"_field\"], valueColumn: \"_value\")"; + $"|> pivot(rowKey:[\"_time\"], columnKey: [\"_field\"], valueColumn: \"_value\")" + + $"|> keep(columns: [\"_time\", \"exchange\", \"ticker\", \"timeframe\", \"openTime\", \"closeTime\", \"open\", \"close\", \"high\", \"low\", \"baseVolume\", \"quoteVolume\", \"TradeCount\", \"takerBuyBaseVolume\", \"takerBuyQuoteVolume\"])"; if (limit != null) { flux += $"|> tail(n:{limit})"; @@ -66,8 +66,8 @@ public class CandleRepository : ICandleRepository $"|> filter(fn: (r) => r[\"exchange\"] == \"{exchange}\")" + $"|> filter(fn: (r) => r[\"ticker\"] == \"{ticker}\")" + $"|> filter(fn: (r) => r[\"timeframe\"] == \"{timeframe}\")" + - $"|> drop(columns: [\"_start\", \"_stop\"])" + - $"|> pivot(rowKey:[\"_time\"], columnKey: [\"_field\"], valueColumn: \"_value\")"; + $"|> pivot(rowKey:[\"_time\"], columnKey: [\"_field\"], valueColumn: \"_value\")" + + $"|> keep(columns: [\"_time\", \"exchange\", \"ticker\", \"timeframe\", \"openTime\", \"closeTime\", \"open\", \"close\", \"high\", \"low\", \"baseVolume\", \"quoteVolume\", \"TradeCount\", \"takerBuyBaseVolume\", \"takerBuyQuoteVolume\"])"; if (limit != null) { flux += $"|> tail(n:{limit})";