Skip to content

Commit fc826ed

Browse files
committed
track number of clickhouse insert operations
1 parent 184181a commit fc826ed

File tree

2 files changed

+7
-1
lines changed

2 files changed

+7
-1
lines changed

internal/metrics/metrics.go

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -155,6 +155,11 @@ var (
155155

156156
// ClickHouse Insert Row Count Metrics
157157
var (
158+
ClickHouseMainStorageInsertOperations = promauto.NewCounter(prometheus.CounterOpts{
159+
Name: "clickhouse_main_storage_insert_operations",
160+
Help: "The total number of insert operations into ClickHouse main storage",
161+
})
162+
158163
ClickHouseMainStorageRowsInserted = promauto.NewCounter(prometheus.CounterOpts{
159164
Name: "clickhouse_main_storage_rows_inserted_total",
160165
Help: "The total number of rows inserted into ClickHouse main storage",

internal/storage/clickhouse.go

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1358,9 +1358,10 @@ func (c *ClickHouseConnector) InsertBlockData(data []common.BlockData) error {
13581358
metrics.ClickHouseTransactionsInserted.Add(float64(txsCount))
13591359
metrics.ClickHouseLogsInserted.Add(float64(logsCount))
13601360
metrics.ClickHouseTracesInserted.Add(float64(tracesCount))
1361+
metrics.ClickHouseMainStorageRowsInserted.Add(float64(end - i))
1362+
metrics.ClickHouseMainStorageInsertOperations.Inc()
13611363
}
13621364

1363-
metrics.ClickHouseMainStorageRowsInserted.Add(float64(len(data)))
13641365
return nil
13651366
}
13661367

0 commit comments

Comments
 (0)