Events entering as tangled channels, passing through transforms and a schema comb, then braiding into one resolved buyer record while a marketing ops lead reads the flow.
graph8 Data Pipelines

Events from your website, product and CRM, in one record per buyer.

Data Pipelines bring in events from your website, product, billing, support and CRM through 500+ source connectors, clean each event as it arrives, and match it to one record per buyer. Your team uses that record in workflows, campaigns, segments, lists, reports and sequences. Your data team writes the rules and the schema, and decides what gets blocked.
Join Demo
The pipeline

How Data Pipelines work, in four stages

Events come in from your sources. A transformation cleans and enriches each one as it arrives. The CDP matches identities and writes one record per buyer. Every part of graph8 reads from that record.

Stage 1

Sources

500+ connectors, SDKs and webhooks bring in events from the tools you use.

Stage 2

Transform

A JavaScript function runs on every event to filter, enrich, route or redact it.

Stage 3

CDP

Matches identities, checks the schema and writes one record per buyer.

Stage 4

Activate

Starts workflows and feeds campaigns, segments, lists, reports and sequences.

Transformations

JavaScript that runs on every event

Your data team writes a function that runs on each event as it comes in: filter out bots, add the company from an email domain, redact personal data, or send the event to a specific destination. Functions are versioned, tested and replayable. There are no batch jobs to schedule and no extra warehouse to run.

transform.jssaved . v3
export default function transform(event) {
  if (/bot|crawler/i.test(event.context?.userAgent || "")) {
    return null
  }

  if (event.traits?.email) {
    event.properties.company_domain =
      event.traits.email.split("@")[1]
  }

  if (event.event === "Demo Booked") {
    event.destinations = ["workflows", "sequencer"]
  }

  return event
}
Example . input event 14:22:18
{
  "userId": "usr_7e3",
  "event": "Demo Booked",
  "traits": { "email": "drew@northwind.io" },
  "context": { "userAgent": "Mozilla/5.0..." }
}
transform.js
Output event . enriched and routed
{
  "userId": "usr_7e3",
  "event": "Demo Booked",
  "traits": { "email": "drew@northwind.io" },
  "properties": { "company_domain": "northwind.io" },
  "destinations": ["workflows", "sequencer"]
}

Versioned and replayable

Every function has a history. Replay any window of events through an old or new version.

Tested before deploy

Run a function against the last 100 events, check the changes, then publish.

Redact personal data

Redact, hash or drop fields before they reach the warehouse.

Schema and governance

A schema for every event

Your team declares which events can be sent and the shape each one must match. The pipeline rejects events that break the schema before they reach your CDP or warehouse, and logs what it blocked and why.

schema . events6 rules
PropertyTypeRequiredRule
eventstringalwaysenum: 12 named events
userIdstringif knownstitched to anonymousId on identify
properties.urlstringfor Page*must be a relative or absolute URL
properties.planstringoptionalenum: free | pro | enterprise
properties.pricenumberfor revenuemust be number, not string
context.userAgentstringoptionalblocked if bot or crawler match
Blocked before it landsschema violation
{
  "event": "Order Completed",
  "properties": {
    "price": "$49.00"
  }
}

Rejected. properties.price must be number, got string.

Nothing is written to the warehouse or synced. The event is logged, so it can be replayed once the source is fixed.

See the sources and destinations
Identity resolution

Identity resolution: three touches, one buyer record

The pipeline matches the identifiers one buyer leaves across devices, sessions and channels, and joins them into one record. Visits from before the buyer gave an email keep their history once the buyer is known.

Anonymous web visitanonymousId: abc_8f2

Form submitemail: drew@northwind.io

Inbound callphone: +1 415 555 0136

D
Drew Bishop

VP Revenue . Northwind

  • anonymousId: abc_8f2
  • email: drew@northwind.io
  • phone: +1 415 555 0136
pipeline_value:$84kintent_score:91last_signal:2h agomeetings_booked:3

Example . one record, with the full history.

Example . Drew's last 5 eventsevents.profile(usr_7e3)
14:22:01 Page Viewed

url: /pricing

14:22:01 Form Submitted

captured email

14:22:02 Identify

stitched anonymousId to usr_7e3

14:22:09 Pricing Plan Viewed

plan: pro

14:22:18 Demo Booked

routed to workflows and sequencer

Tailor

Tailor: change your website for each segment

Once a buyer is matched, Tailor changes the HTML on your live pages for each segment. Change a hero, swap a CTA, hide a banner. Marketing does it without a CMS edit or a new build, in the same pipeline that handles the data.

Default . every visitor
Sign up for free

700M+ contacts. Search anyone for free.

Start Free
Tailor rule
when segment matches
"high-intent . enterprise"

inject hero-enterprise.html
into [data-tailor=hero]
Example . tailored for Drew, high intent
Drew, here is pricing for Northwind.

The Team plan, with every user included. Join the next demo.

Join Demo

No CMS edit

Change any element by its selector. Marketing controls the variant without writing code.

Segment-driven

Rules read from the same buyer record, so the segments in the CDP decide who sees what.

Measured in your reports

Each variant sends its own events back into the pipeline, so the difference shows in your reports.

Surface controls

Controls for each graph8 widget on your site

Chat, forms, the tracking snippet, the newsletter widget, Tailor and the voice widget. Turn each one on or off, and limit it to an audience, a page or a campaign. The CDP decides who sees what.

Example . widgets on your site5 controls on

Web chat

Chat widget on your site

audience: high-intent visitors

Forms

Inline and popup form capture

Tracking snippet

Identify and page events

Newsletter widget

Email subscribe block

Tailor

HTML personalization on the page

campaign: q3-pro-launch

Voice widget

Click-to-call from your site

route: /pricing/*

By audience, page or campaign

Conditions combine. For example, show chat to high-intent visitors on /pricing during the Q3 campaign only.

No code release

Turn a widget on or off from the workspace. The change applies to every page without a new release.

Sources and destinations

Where the data comes from and where it goes

500+ source connectors across CRM, databases, payments, analytics, support, e-commerce, productivity and HR. Data can sync out to Snowflake, BigQuery and Redshift.

HubSpot Salesforce Stripe Shopify PostgreSQL MongoDB Google Analytics Mixpanel Segment Zendesk Intercom
Snowflake BigQuery Redshift

500+ source connectors. Snowflake, BigQuery and Redshift as destinations. Webhooks, Zapier, Make and reverse ETL.

Browse the full catalog
Activation

Where your team uses the data in graph8

Every part of graph8 reads the same buyer record. When the record changes in the CDP, the workflows, campaigns, segments, lists, reports and sequences that use it see the change.

Workflows

Any event can start a workflow when the data arrives.

Campaigns

Personalize messages from the buyer record, without copying data between tools.

Segments

Segments update as new data arrives, not in a nightly batch.

Lists

Saved lists stay current. Send a list to a sequence in one click.

Reports

Pipeline, funnel and source reports update from the same record as data arrives.

Sequences

Outbound sequences read the latest data and pause when a deal moves.

How it fits

How Data Pipelines fit with the rest of graph8

Data Pipelines feed the buyer graph, the record of every account, contact, signal and conversation you hold. The agents read and write to the same record. The apps show it, and reports run on it.

The pipelines bring the data in, and the agents do the work with it. Your team works from one system instead of tools joined by exports and CSV files.

07 / Pricing

You pay for what the agents run. Every user is included on the Team plan.

Execution credits send, call, and run agents. Contact credits reveal and enrich the people you target. Three ways in.

For trying it out Pay as you go
Free to start

A free entry point to the full platform. No credit card.

  • 1,000 contact reveals to start
  • 500 execution actions free
  • Full platform access, no card
  • Then $0.05 per credit
Start Free
For data in your AI tools MCP Unlimited
$25 / user

Unlimited contact data, in the tools you already use.

  • Unlimited contact data, fair use
  • 2,500 execution credits a month
  • Priced per user, not per org
Claude ChatGPT Cursor VS Code
Start Free
Recommended
The full platform Team plan
$99 / mo

Unlimited users and data. Every app, one bill.

  • Campaigns, dialer, AI voice, and AI workflows
  • Meetings routed and booked for you
  • 10,000 execution credits a month
  • Unlimited users, no seat fees
  • 7-day free trial, no credit card
Start Free

Everything in the Team plan

$99 / mo, all included

The $99 Team plan is the full platform: everything below, for the whole org. MCP Unlimited and Pay as you go are lighter entry points with usage and seat limits.

What the agents run

10,000 credits included
  • Campaigns and sending infrastructure Mailboxes, domains, and deliverability run for you, end to end.
  • 5-channel sequencer Email, phone, LinkedIn, SMS, and WhatsApp in automated sequences.
  • Dialer and AI voice agents Reps call from the built-in dialer. AI voice answers inbound calls, makes outbound ones and books the meeting.
  • AI inbox Every inbound email, LinkedIn message and reply sorted, drafted and answered.
  • Meeting routing and booking Route leads to the right rep and book the meeting automatically.
  • CRM, pipeline, and quotes Deals, quotes, and each rep's daily list in My Desk.
  • Studio content engine Brand, newsletters, landing pages, ads, and campaign content.
  • AI agents and workflows Operator and Executor agents for RevOps, deal reviews, and SDR work.

Contact data

Included
  • MCP Unlimited for every user A $25 per user value, included for the whole org on the Team plan.
  • No monthly cap on contact data Reveals, lookups, enrichments, and exports run org-wide, every seat.
  • Buying signals Visitors, intent, hiring, and job-change signals on every account.
  • Waterfall enrichment Third-party providers, pay on match or bring your own keys.
  • Free search and browse Your whole team explores 700M+ contacts and 100M+ companies.

For the whole team

Always on
  • Unlimited users, no seat fees Invite everyone. Pricing never scales with headcount.
  • Every feature unlocked No tiers gating voice, enrichment, sequencer, campaigns, or desktop.
  • Built-in CDP and integrations Warehouse, 500+ connectors, two-way CRM sync included.
  • Month-to-month, no contracts Cancel anytime.
  • Fair-use rate limits Limits apply on all plans. They guard against scraping, not real GTM work.

Execution credits send, call, and run agents. Contact credits reveal and enrich the people you target.

Start free

Try Data Pipelines with your own data

Sign-up takes about ten seconds with Google or Microsoft. Connect a source, and its events land on your buyer records, ready for workflows, campaigns and reports. Free to start, no card.