search

noctarius / timescaledb-event-streamer

timescaledb-event-streamer is a command line program to create a stream of CDC (Change Data Capture) TimescaleDB Hypertable events from a PostgreSQL installation running the TimescaleDB extension.
Apache License 2.0
40 stars 3 forks source link

Candlestick type #173

Open neodino opened 8 months ago

neodino commented 8 months ago

Hello Getting error for candlestick as it seams not supported type:

CDC (Change Data Capture) for TimescaleDB Hypertable
timescaledb-event-streamer version 0.12.0 (git revision unknown; branch unknown)
Using configuration file from environment variable
Loading configuration file: /etc/config.toml
[2023/12/22T01:40:42.581] [VERBOSE] [SystemCatalog] Entry Added: Hypertable 1 => {id:1 schemaName:public tableName:stocks_real_time associatedSchemaName:_timescaledb_internal associatedTablePrefix:_hyper_1 compressedHypertableId:<nil> compressionState:0 replicaIdentity:dviewSchema:<nil> viewName:<nil> columns:[]}
[2023/12/22T01:40:42.622] [VERBOSE] [SystemCatalog] Entry Added: Hypertable 3 => {id:3 schemaName:_timescaledb_internal tableName:_materialized_hypertable_3 associatedSchemaName:_timescaledb_internal associatedTablePrefix:_hyper_3 compressedHypertableId:<nil> compressionState:0 replicaIdentity:dviewSchema:public viewName:candlestick_5min columns:[]}
[2023/12/22T01:40:42.693] [VERBOSE] [SystemCatalog] Entry Added: Hypertable 6 => {id:6 schemaName:_timescaledb_internal tableName:_materialized_hypertable_6 associatedSchemaName:_timescaledb_internal associatedTablePrefix:_hyper_6 compressedHypertableId:<nil> compressionState:0 replicaIdentity:dviewSchema:public viewName:candlestick_1hour columns:[]}
[2023/12/22T01:40:42.879] [VERBOSE] [SystemCatalog] Entry Added: Hypertable 5 => {id:5 schemaName:_timescaledb_internal tableName:_materialized_hypertable_5 associatedSchemaName:_timescaledb_internal associatedTablePrefix:_hyper_5 compressedHypertableId:<nil> compressionState:0 replicaIdentity:dviewSchema:public viewName:candlestick_30min columns:[]}
[2023/12/22T01:40:42.932] [VERBOSE] [SystemCatalog] Entry Added: Hypertable 4 => {id:4 schemaName:_timescaledb_internal tableName:_materialized_hypertable_4 associatedSchemaName:_timescaledb_internal associatedTablePrefix:_hyper_4 compressedHypertableId:<nil> compressionState:0 replicaIdentity:dviewSchema:public viewName:candlestick_15min columns:[]}
[2023/12/22T01:40:42.974] [VERBOSE] [SystemCatalog] Entry Added: Hypertable 2 => {id:2 schemaName:_timescaledb_internal tableName:_materialized_hypertable_2 associatedSchemaName:_timescaledb_internal associatedTablePrefix:_hyper_2 compressedHypertableId:<nil> compressionState:0 replicaIdentity:dviewSchema:public viewName:candlestick_1min columns:[]}
[2023/12/22T01:40:43.024] [VERBOSE] [SystemCatalog] Entry Added: Chunk 1 for Hypertable "public"."stocks_real_time" => {id:1 hypertableId:1 schemaName:_timescaledb_internal tableName:_hyper_1_1_chunk compressedChunkId:<nil> dropped:false status:0}
[2023/12/22T01:40:43.025] [VERBOSE] [SystemCatalog] Entry Added: Chunk 2 for Hypertable "_timescaledb_internal"."_materialized_hypertable_2" => {id:2 hypertableId:2 schemaName:_timescaledb_internal tableName:_hyper_2_2_chunk compressedChunkId:<nil> dropped:false status:0}
[2023/12/22T01:40:43.025] [VERBOSE] [SystemCatalog] Entry Added: Chunk 3 for Hypertable "_timescaledb_internal"."_materialized_hypertable_3" => {id:3 hypertableId:3 schemaName:_timescaledb_internal tableName:_hyper_3_3_chunk compressedChunkId:<nil> dropped:false status:0}
[2023/12/22T01:40:43.025] [VERBOSE] [SystemCatalog] Entry Added: Chunk 5 for Hypertable "_timescaledb_internal"."_materialized_hypertable_4" => {id:5 hypertableId:4 schemaName:_timescaledb_internal tableName:_hyper_4_5_chunk compressedChunkId:<nil> dropped:false status:0}
[2023/12/22T01:40:43.025] [VERBOSE] [SystemCatalog] Entry Added: Chunk 4 for Hypertable "_timescaledb_internal"."_materialized_hypertable_5" => {id:4 hypertableId:5 schemaName:_timescaledb_internal tableName:_hyper_5_4_chunk compressedChunkId:<nil> dropped:false status:0}
[2023/12/22T01:40:43.025] [VERBOSE] [SystemCatalog] Entry Added: Chunk 6 for Hypertable "_timescaledb_internal"."_materialized_hypertable_6" => {id:6 hypertableId:6 schemaName:_timescaledb_internal tableName:_hyper_6_6_chunk compressedChunkId:<nil> dropped:false status:0}
[2023/12/22T01:40:43.129] [VERBOSE] [SystemCatalog] Entry Added: Vanilla Table 18865 => {relId:18865 schemaName:public tableName:ibkr_stocks replicaIdentity:dcolumns:[]}
[2023/12/22T01:40:43.183] [VERBOSE] [SystemCatalog] Schema Update: Hypertable 2 => map[candlestick:added: {name:candlestick dataType:17664 modifiers:-1 pgType:candlestick nullable:true primaryKey:false keySeq:<nil> indexName:<nil> replicaIdent:false defaultValue:<nil> dimension:false dimAligned:false dimType:space dimSeq:<nil>maxCharLength:<nil>} symbol:added: {name:symbol dataType:25 modifiers:-1 pgType:text nullable:true primaryKey:false keySeq:<nil> indexName:<nil> replicaIdent:false defaultValue:<nil> dimension:false dimAligned:false dimType:space dimSeq:<nil>maxCharLength:<nil>} ts:added: {name:ts dataType:1184 modifiers:-1 pgType:timestamptz nullable:false primaryKey:false keySeq:<nil> indexName:<nil> replicaIdent:false defaultValue:<nil> dimension:true dimAligned:true dimType:time dimSeq:1maxCharLength:<nil>}]
Type 17664 is not a record type
image

Any plan to add it? Thanks, Great project!