Monitor failed payments in Postgres
Catch failed charges the second they happen, with the customer, amount, and decline reason attached, so a billing problem becomes a message instead of a churn surprise.
01source
02pipeline · 2 steps
- 01CTLfilter.matchamount ≥ 50.00 only
- 02ENRenrich.entitycustomer → plan · MRR · CSM
03destinations · 1
- towarehouse.pgPostgrestableevents.signups
the event
You emit payment.failed 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
- emailstring
- amountnumberminor units
- currencystringISO 4217
- reasonstringprocessor decline code
- attemptnumber
emit it
From your code with the TypeScript SDK — or any language over the REST endpoint and signed webhook ingress.
import { ingest } from "@ingestlayer/sdk";
await ingest("payment.failed", {
customer_id: charge.customer,
email: charge.receipt_email,
amount: charge.amount,
currency: charge.currency,
reason: charge.failure_code,
attempt: charge.attempt,
}, {
idempotencyKey: `${charge.id}:${charge.attempt}`,
});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.
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 avoid alert spam on retries?
- Filter on the attempt field, or set a dedupe window so repeated failures for the same charge collapse into one alert.
- Can I only alert on high-value customers?
- Yes. enrich.entity pulls MRR onto the event, then a filter keeps only the ones above your threshold.
- Where does the decline reason come from?
- Whatever you put in the reason field — usually the processor's decline code. ingestlayer passes it through untouched.
failed payments, routed elsewhere
- Monitor failed payments in SlackSlack
- Monitor failed payments in DiscordDiscord
- Monitor failed payments in TelegramTelegram
- Monitor failed payments in EmailEmail
- Monitor failed payments in WebhookWebhook
- Monitor failed payments in NotionNotion
more, into Postgres
- Track user signups in Postgrestrack
- Route support escalations in Postgresalert
- Track waitlist signups in Postgrestrack
- Track new subscriptions in Postgrestrack
- Track canceled subscriptions in Postgrestrack
- Track successful payments in Postgrestrack
- Track trial conversions in Postgrestrack
- Track form submissions in Postgrestrack
- Track feature usage in Postgrestrack
- Track file uploads in Postgrestrack
- Monitor failed logins in Postgresmonitor
- Monitor usage-limit hits in Postgresmonitor
- Monitor error spikes in Postgresmonitor
- Monitor cron-job health in Postgresmonitor
- Monitor CI/CD build status in Postgresmonitor
- Flag high-value leads in Postgresalert
- Catch churn-risk signals in Postgresalert
- everything you can pipe to Postgreshub