fix(examples): query and tables

examples/database/README.md

@@ -77,7 +77,6 @@ Launch the example (database, event collector and seeder):
 docker compose up -d
 ```
 
-
 ## Checking events
 
 Read more in the general examples [README](../README.md#Checking-events-in-OpenMeter).

examples/database/config.yaml

@@ -1,15 +1,15 @@
 input:
   sql_select:
-    driver: clickhouse
-    dsn: "${CLICKHOUSE_DSN}"
+    driver: "${DATABASE_DRIVER}"
+    dsn: "${DATABASE_DSN}"
     table: messages
     columns:
       - message_id
       - account_id
       - message
       - time
     where: time >= ?
-    args_mapping: root = [ now().ts_unix() - 30 ]
+    args_mapping: 'root = [ (now().ts_unix() - 30).ts_format(format: "2006-01-02 15:04:05", tz: "UTC") ]'
 
 pipeline:
   processors:

examples/database/docker-compose.common.yaml

@@ -3,6 +3,7 @@ version: "3.9"
 services:
   collector:
     image: ghcr.io/openmeterio/benthos-openmeter
+    pull_policy: always
     command: benthos -c /etc/benthos/config.yaml
     restart: always
     env_file:
@@ -12,6 +13,7 @@ services:
 
   seeder:
     image: ghcr.io/openmeterio/benthos-openmeter
+    pull_policy: always
     command: benthos -c /etc/benthos/config.yaml
     restart: always
     volumes:

examples/database/seed/config.yaml

@@ -39,7 +39,7 @@ output:
                 this.sender,
                 this.recipient,
                 this.message,
-                this.time.ts_format("2006-01-02 15:04:05"),
+                this.time.ts_format(format: "2006-01-02 15:04:05", tz: "UTC"),
               ]
             init_files:
               - init.sql

examples/database/seed/init.clickhouse.sql

@@ -1,9 +1,9 @@
-CREATE TABLE IF NOT EXISTS messages (
-    message_id UUID,
-    account_id String,
-    sender String,
-    recipient String,
-    message String,
-    time DateTime
-) ENGINE = MergeTree()
-PRIMARY KEY (message_id);
+CREATE TABLE
+    IF NOT EXISTS messages (
+        message_id UUID,
+        account_id String,
+        sender String,
+        recipient String,
+        message String,
+        time DateTime('UTC')
+    ) ENGINE = MergeTree() PRIMARY KEY (message_id);

examples/database/seed/init.postgres.sql

@@ -1,8 +1,9 @@
-CREATE TABLE IF NOT EXISTS messages (
-    message_id UUID PRIMARY KEY,
-    account_id TEXT,
-    sender TEXT,
-    recipient TEXT,
-    message TEXT,
-    time TIMESTAMP
-);
+CREATE TABLE
+    IF NOT EXISTS messages (
+        message_id UUID PRIMARY KEY,
+        account_id TEXT,
+        sender TEXT,
+        recipient TEXT,
+        message TEXT,
+        time TIMESTAMPTZ
+    );