Connectors 93 built-in connectors for databases, APIs, payments, communication, and more
Pipes ships with 93 pre-built connectors across 15 categories. Each connector handles authentication, rate limiting, and error handling so you can focus on your workflow logic.
Connector Operations PostgreSQL Query, insert, update, delete MySQL Query, insert, update, delete MongoDB Find, insert, update, aggregate Redis Get, set, publish, subscribe Elasticsearch Search, index, bulk DynamoDB Get, put, query, scan Supabase CRUD, realtime, storage ClickHouse Query, insert, batch
Connector Operations Slack Send message, create channel, upload Discord Send message, manage channels Twilio SMS, voice, WhatsApp SendGrid Email, templates, contacts Resend Transactional email Mailgun Email, mailing lists Telegram Messages, bots, media Microsoft Teams Messages, channels, cards WhatsApp Business Messages, templates, media
Connector Operations Stripe Charges, subscriptions, invoices PayPal Payments, payouts Square Payments, catalog, orders Braintree Transactions, customers Adyen Payments, payouts, platforms Wise Transfers, quotes, accounts
Connector Operations AWS S3 Upload, download, list, presign Google Cloud Storage Upload, download, list Azure Blob Upload, download, list Cloudflare R2 Upload, download, list Backblaze B2 Upload, download, list MinIO Upload, download, list
Connector Operations Salesforce CRUD, SOQL, bulk HubSpot Contacts, deals, tickets Pipedrive Deals, contacts, activities Zoho CRM Records, modules, analytics Freshsales Contacts, deals, tasks Close Leads, contacts, activities
Connector Operations Datadog Metrics, events, logs PagerDuty Incidents, alerts, escalation Opsgenie Alerts, on-call, incidents Sentry Issues, events, releases New Relic Events, metrics, NRQL Grafana Annotations, dashboards
Connector Operations Apache Kafka Produce, consume, admin RabbitMQ Publish, consume, manage AWS SQS Send, receive, delete AWS SNS Publish, subscribe Azure Service Bus Send, receive, peek Google Pub/Sub Publish, subscribe NATS Publish, subscribe, request
Connector Operations SAP RFC, BAPI, iDoc Oracle Query, stored procedures ServiceNow Records, incidents, workflows Jira Issues, projects, boards Confluence Pages, spaces, search Zendesk Tickets, users, organizations Intercom Conversations, contacts, events
Connector Operations OpenAI Chat, embeddings, images Anthropic Messages, tools Google Gemini Generate, embed Cohere Generate, classify, embed Replicate Run models, predictions Hugging Face Inference, models Pinecone Upsert, query, delete Weaviate Objects, search, batch
Connector Operations GitHub Repos, issues, PRs, actions GitLab Projects, MRs, pipelines Bitbucket Repos, PRs, pipelines Linear Issues, projects, cycles Notion Pages, databases, blocks Airtable Records, tables, views Google Sheets Read, write, append
Connector Operations Auth0 Users, roles, organizations Okta Users, groups, apps Firebase Auth Users, tokens, providers AWS Cognito Users, groups, pools Keycloak Users, realms, clients
Connector Operations Shopify Orders, products, customers WooCommerce Orders, products, coupons BigCommerce Orders, products, customers Magento Orders, products, categories Medusa Orders, products, carts
Connector Operations Twitter/X Tweets, DMs, search LinkedIn Posts, messages, profiles Facebook Posts, pages, insights Instagram Posts, stories, insights YouTube Videos, channels, comments
Connector Operations Google Analytics Events, reports Mixpanel Events, profiles, reports Amplitude Events, users, cohorts Segment Track, identify, group
Connector Operations Vault (HashiCorp) Secrets, encryption, PKI AWS KMS Encrypt, decrypt, sign CrowdStrike Detections, incidents Snyk Vulnerabilities, projects
Before using a connector in a workflow, register it with credentials:
await npayload.pipes.connectors. register ({ identifier: 'my-stripe' , type: 'stripe' , credentials: { apiKey: process.env. STRIPE_SECRET_KEY , }, }); Reference the connector in an action node:
workflow. addNode ({ type: 'http' , connector: 'my-stripe' , operation: 'createCharge' , params: { amount: '{{ payload.amount }}' , currency: 'usd' , customer: '{{ payload.customerId }}' , }, });
Credentials are encrypted at rest using AES-256
Connector secrets never appear in workflow logs
Each connector supports scoped permissions
Credentials can be rotated without modifying workflows