streamer

Streamer

A streaming example that streams records from a Postgres table/query and writes in JSON format them to a BLOB.

Setup

Dependencies:

• Install Docker
• Install Deno
• Install Apex
• Install NanoBus
• Install Go 1.19+
• Install TinyGo 0.26+

Running

Start Postgres and Jaeger inside Docker

docker-compose up

Build the application

apex build

Option 1: Run NanoBus as a server

nanobus run --debug

Invoke via HTTP

curl -L -X POST 'http://localhost:8080/process' \
-H 'Content-Type: application/json' \
--data-raw '{}'

Option 2: Invoke in the terminal

echo '{}' | nanobus invoke --developer-mode bus.ts streamer.v1.Streamer::process