Skip to content

Commit

Permalink
feat(migrations/clickhouse): add beacon block gas fields
Browse files Browse the repository at this point in the history
  • Loading branch information
@Savid
Savid committed Aug 7, 2024
1 parent dfa7591 commit a2721c0
Show file tree
Hide file tree
Showing 3 changed files with 64 additions and 0 deletions.
10 changes: 10 additions & 0 deletions deploy/local/docker-compose/vector-kafka-clickhouse.yaml
View file
Original file line number Diff line number Diff line change
Expand Up @@ -951,6 +951,11 @@ transforms:
.execution_payload_block_hash = .data.message.body.execution_payload.block_hash
.execution_payload_block_number = .data.message.body.execution_payload.block_number
.execution_payload_fee_recipient = .data.message.body.execution_payload.fee_recipient
.execution_payload_base_fee_per_gas = .data.message.body.execution_payload.base_fee_per_gas
.execution_payload_blob_gas_used = .data.message.body.execution_payload.blob_gas_used
.execution_payload_excess_blob_gas = .data.message.body.execution_payload.excess_blob_gas
.execution_payload_gas_limit = .data.message.body.execution_payload.gas_limit
.execution_payload_gas_used = .data.message.body.execution_payload.gas_used
.execution_payload_state_root = .data.message.body.execution_payload.state_root
.execution_payload_parent_hash = .data.message.body.execution_payload.parent_hash
.execution_payload_transactions_count = .meta.client.additional_data.transactions_count
Expand Down Expand Up @@ -1016,6 +1021,11 @@ transforms:
.execution_payload_block_hash = .data.message.body.execution_payload.block_hash
.execution_payload_block_number = .data.message.body.execution_payload.block_number
.execution_payload_fee_recipient = .data.message.body.execution_payload.fee_recipient
.execution_payload_base_fee_per_gas = .data.message.body.execution_payload.base_fee_per_gas
.execution_payload_blob_gas_used = .data.message.body.execution_payload.blob_gas_used
.execution_payload_excess_blob_gas = .data.message.body.execution_payload.excess_blob_gas
.execution_payload_gas_limit = .data.message.body.execution_payload.gas_limit
.execution_payload_gas_used = .data.message.body.execution_payload.gas_used
.execution_payload_state_root = .data.message.body.execution_payload.state_root
.execution_payload_parent_hash = .data.message.body.execution_payload.parent_hash
.execution_payload_transactions_count = .meta.client.additional_data.transactions_count
Expand Down
27 changes: 27 additions & 0 deletions deploy/migrations/clickhouse/047_block_execution_payloads.down.sql
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,27 @@
ALTER TABLE canonical_beacon_block ON CLUSTER '{cluster}'
DROP COLUMN execution_payload_base_fee_per_gas,
DROP COLUMN execution_payload_blob_gas_used,
DROP COLUMN execution_payload_excess_blob_gas,
DROP COLUMN execution_payload_gas_limit,
DROP COLUMN execution_payload_gas_used;

ALTER TABLE canonical_beacon_block_local ON CLUSTER '{cluster}'
DROP COLUMN execution_payload_base_fee_per_gas,
DROP COLUMN execution_payload_blob_gas_used,
DROP COLUMN execution_payload_excess_blob_gas,
DROP COLUMN execution_payload_gas_limit,
DROP COLUMN execution_payload_gas_used;

ALTER TABLE beacon_api_eth_v2_beacon_block ON CLUSTER '{cluster}'
DROP COLUMN execution_payload_base_fee_per_gas,
DROP COLUMN execution_payload_blob_gas_used,
DROP COLUMN execution_payload_excess_blob_gas,
DROP COLUMN execution_payload_gas_limit,
DROP COLUMN execution_payload_gas_used;

ALTER TABLE beacon_api_eth_v2_beacon_block_local ON CLUSTER '{cluster}'
DROP COLUMN execution_payload_base_fee_per_gas,
DROP COLUMN execution_payload_blob_gas_used,
DROP COLUMN execution_payload_excess_blob_gas,
DROP COLUMN execution_payload_gas_limit,
DROP COLUMN execution_payload_gas_used;
27 changes: 27 additions & 0 deletions deploy/migrations/clickhouse/047_block_execution_payloads.up.sql
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,27 @@
ALTER TABLE canonical_beacon_block_local ON CLUSTER '{cluster}'
ADD COLUMN execution_payload_base_fee_per_gas Nullable(UInt128) COMMENT 'Base fee per gas for execution payload' CODEC(ZSTD(1)) AFTER execution_payload_fee_recipient,
ADD COLUMN execution_payload_blob_gas_used Nullable(UInt64) COMMENT 'Gas used for blobs in execution payload' CODEC(ZSTD(1)) AFTER execution_payload_base_fee_per_gas,
ADD COLUMN execution_payload_excess_blob_gas Nullable(UInt64) COMMENT 'Excess gas used for blobs in execution payload' CODEC(ZSTD(1)) AFTER execution_payload_blob_gas_used,
ADD COLUMN execution_payload_gas_limit Nullable(UInt64) COMMENT 'Gas limit for execution payload' CODEC(DoubleDelta, ZSTD(1)) AFTER execution_payload_excess_blob_gas,
ADD COLUMN execution_payload_gas_used Nullable(UInt64) COMMENT 'Gas used for execution payload' CODEC(ZSTD(1)) AFTER execution_payload_gas_limit;

ALTER TABLE canonical_beacon_block ON CLUSTER '{cluster}'
ADD COLUMN execution_payload_base_fee_per_gas Nullable(UInt128) COMMENT 'Base fee per gas for execution payload' CODEC(ZSTD(1)) AFTER execution_payload_fee_recipient,
ADD COLUMN execution_payload_blob_gas_used Nullable(UInt64) COMMENT 'Gas used for blobs in execution payload' CODEC(ZSTD(1)) AFTER execution_payload_base_fee_per_gas,
ADD COLUMN execution_payload_excess_blob_gas Nullable(UInt64) COMMENT 'Excess gas used for blobs in execution payload' CODEC(ZSTD(1)) AFTER execution_payload_blob_gas_used,
ADD COLUMN execution_payload_gas_limit Nullable(UInt64) COMMENT 'Gas limit for execution payload' CODEC(DoubleDelta, ZSTD(1)) AFTER execution_payload_excess_blob_gas,
ADD COLUMN execution_payload_gas_used Nullable(UInt64) COMMENT 'Gas used for execution payload' CODEC(ZSTD(1)) AFTER execution_payload_gas_limit;

ALTER TABLE beacon_api_eth_v2_beacon_block_local ON CLUSTER '{cluster}'
ADD COLUMN execution_payload_base_fee_per_gas Nullable(UInt128) COMMENT 'Base fee per gas for execution payload' CODEC(ZSTD(1)) AFTER execution_payload_fee_recipient,
ADD COLUMN execution_payload_blob_gas_used Nullable(UInt64) COMMENT 'Gas used for blobs in execution payload' CODEC(ZSTD(1)) AFTER execution_payload_base_fee_per_gas,
ADD COLUMN execution_payload_excess_blob_gas Nullable(UInt64) COMMENT 'Excess gas used for blobs in execution payload' CODEC(ZSTD(1)) AFTER execution_payload_blob_gas_used,
ADD COLUMN execution_payload_gas_limit Nullable(UInt64) COMMENT 'Gas limit for execution payload' CODEC(DoubleDelta, ZSTD(1)) AFTER execution_payload_excess_blob_gas,
ADD COLUMN execution_payload_gas_used Nullable(UInt64) COMMENT 'Gas used for execution payload' CODEC(ZSTD(1)) AFTER execution_payload_gas_limit;

ALTER TABLE beacon_api_eth_v2_beacon_block ON CLUSTER '{cluster}'
ADD COLUMN execution_payload_base_fee_per_gas Nullable(UInt128) COMMENT 'Base fee per gas for execution payload' CODEC(ZSTD(1)) AFTER execution_payload_fee_recipient,
ADD COLUMN execution_payload_blob_gas_used Nullable(UInt64) COMMENT 'Gas used for blobs in execution payload' CODEC(ZSTD(1)) AFTER execution_payload_base_fee_per_gas,
ADD COLUMN execution_payload_excess_blob_gas Nullable(UInt64) COMMENT 'Excess gas used for blobs in execution payload' CODEC(ZSTD(1)) AFTER execution_payload_blob_gas_used,
ADD COLUMN execution_payload_gas_limit Nullable(UInt64) COMMENT 'Gas limit for execution payload' CODEC(DoubleDelta, ZSTD(1)) AFTER execution_payload_excess_blob_gas,
ADD COLUMN execution_payload_gas_used Nullable(UInt64) COMMENT 'Gas used for execution payload' CODEC(ZSTD(1)) AFTER execution_payload_gas_limit;

0 comments on commit a2721c0

Please sign in to comment.