How do I keep the channel quiet?

Filter on amount so routine charges pass silently to the warehouse, while only large payments reach a human.

Can I split by currency?

Branch on the currency field to route EU and US revenue to different channels or owners.

Will retries double-count?

No. The charge id as idempotencyKey collapses retries, so one cleared payment is one event.

Track successful payments in Postgres

Surface the payments that matter — a big invoice cleared, an annual renewed — without drowning the channel in every routine charge.

01source

sourcesdk.eventTypeScript SDK

matchpayment.succeeded

02pipeline · 2 steps

01CTLfilter.matchamount ≥ 500.00 only
02ENRenrich.entitycustomer → plan · account owner

03destinations · 1

towarehouse.pgPostgres
tableevents.signups

the event

You emit payment.succeeded with this shape. The TypeScript SDK keeps the call type-safe, and the event is stored whole — so every field below is available to the pipeline by name.

customer_idstring
amountnumberminor units
currencystringISO 4217
invoice_idstring
methodstringcard | sepa | invoice

emit it

From your code with the TypeScript SDK — or any language over the REST endpoint and signed webhook ingress.

emit payment.succeeded

import { ingest } from "@ingestlayer/sdk";

await ingest("payment.succeeded", {
  customer_id: charge.customer,
  amount:      charge.amount,
  currency:    charge.currency,
  invoice_id:  charge.invoice,
  method:      charge.payment_method_type,
}, {
  idempotencyKey: charge.id,
});

route it to Postgres

Insert each event as a row into a table in your own Postgres.

01
add the connection
Paste a Postgres connection string. Connections originate from our EU region — allowlist those egress IPs on your database.
02
point at a table
Name the target table. Top-level event fields map to columns, and the full payload is also available as a jsonb column.
03
map columns
Match event fields to columns with $event.* references, or accept the default mapping into a typed events table.

in postgresdelivered

INSERT INTO events.signups
  (user_id, email, plan, source, payload)
VALUES
  ('u_018f', 'ada@acme.com', 'pro',
   'marketing-site', '{ … }'::jsonb);

notes

The target table must already exist with compatible column types; ingestlayer never runs DDL on your database.
Connections come from fixed EU egress IPs — add them to your firewall, or inserts will time out.
Use a jsonb column for the full payload when your event shape changes often, so a new field never breaks the insert.

questions

How do I keep the channel quiet?: Filter on amount so routine charges pass silently to the warehouse, while only large payments reach a human.
Can I split by currency?: Branch on the currency field to route EU and US revenue to different channels or owners.
Will retries double-count?: No. The charge id as idempotencyKey collapses retries, so one cleared payment is one event.

build this pipeline or read the quickstart →