Databases

• Apache Druid (PyDruid) (apache_druid/using_pydruid) - Sync data from Apache Druid using the PyDruid library with native query capabilities, retry logic, and optimized data retrieval.
• Apache Druid (SQL API) (apache_druid/using_sql) - Sync data from Apache Druid using Druid's SQL API with time-based pagination and incremental sync.
• Apache HBase (apache_hbase) - Connect and sync data from Apache HBase using happybase and thrift libraries
• Apache Hive (PyHive) (apache_hive/using_pyhive) - Sync data from Apache Hive using PyHive
• Apache Hive (SQLAlchemy) (apache_hive/using_sqlalchemy) - Sync data from Apache Hive using SQLAlchemy with PyHive
• ArangoDB (arango_db) - Sync document and edge collections from ArangoDB multi-model database
• AVEVA PI (aveva_pi) - Sync asset hierarchy and time-series data from AVEVA PI (formerly OSIsoft PI) via PI Web API
• Cassandra (cassandra) - Connect and sync data from Cassandra database
• ClickHouse (clickhouse) - Sync data from ClickHouse database
• Couchbase Capella (couchbase_capella) - Sync data from Couchbase Capella
• Couchbase Magma (couchbase_magma) - Sync data from self-managed Couchbase Server using Magma storage
• Dgraph (dgraph) - Sync e-commerce product catalog from Dgraph graph databases
• AWS DocumentDB (documentdb) - Connect to AWS DocumentDB and sync collections (Hybrid Deployment compatible)
• DolphinDB (dolphin_db) - Sync data from DolphinDB database
• DragonflyDB (dragonfly_db) - Sync high-performance in-memory data from DragonflyDB
• EHI (Simple) (ehi/simple_ehi) - Sync EHI tables such as Caboodle from Microsoft SQL Server.
• EHI (High Volume) (ehi/high_volume_ehi) - Sync high-volume EHI tables from Microsoft SQL Server using keyset and offset pagination with parallel processing
• Firebird (firebird_db) - Sync data from Firebird DB
• Greenplum (greenplum_db) - Sync data from Greenplum database
• IBM Db2 (simple_ibm_db2) - Sync data from IBM Db2 using the ibm_db library.
• IBM Db2 (Log-Based Replication) (ibm_db2_log_based_replication) - Sync IBM Db2 data using log-based CDC via the ASN SQL Replication framework, reading from Change Data tables without polling the source.
• IBM Db2 for i (ibm_db2i) - Sync data from IBM Db2 for i (IBM i / AS400) using pyodbc with the IBM i Access ODBC Driver.
• IBM Informix (ibm_db) (ibm_informix_using_ibm_db) - Sync data from IBM Informix using the ibm_db library.
• IBM Informix (JayDeBeApi) (ibm_informix_using_jaydebeapi) - Sync data from IBM Informix using jaydebeapi with an external JDBC driver.
• JanusGraph (janus_graph) - Sync data from JanusGraph.
• InfluxDB (influx_db) - Sync time-series data from InfluxDB
• Neo4j (neo4j) - Extract data from Neo4j graph databases
• QuestDB (quest_db) - Sync high-performance time series data from QuestDB
• RavenDB (raven_db) - Sync document data from RavenDB NoSQL database
• Redis (redis) - Sync gaming leaderboards and player statistics from Redis
• RethinkDB (rethink_db) - Sync data from RethinkDB real-time database
• SAP HANA (sap_hana_sql) - Connect to SAP HANA SQL Server using hdbcli
• SQL Server (sql_server) - Connect to SQL Server using pyodbc
• Sybase IQ (sybase_iq) - Sync data from Sybase IQ using the FreeTDS driver and PyODBC.
• Sybase ASE (sybase_ase) - Sync data from Sybase ASE using the FreeTDS driver and PyODBC.
• Teradata Vantage (teradata) - Sync data from Teradata Vantage database
• TiDB (tidb) - Sync data incrementally from TiDB databases
• TimescaleDB (timescale_db) - Sync time-series and vector data from TimescaleDB
• YugabyteDB (yugabyte_db) - Sync data from YugabyteDB distributed SQL database

Cloud Data Warehouses

• AWS Athena (Boto3) (aws_athena/using_boto3) - Sync data from AWS Athena using Boto3
• AWS Athena (SQLAlchemy with PyAthena) (aws_athena/using_sqlalchemy) - Sync data from AWS Athena using SQLAlchemy with PyAthena
• AWS DynamoDB (IAM Role Authentication) (aws_dynamo_db_authentication) - Connect and sync data from AWS DynamoDB
• AWS RDS Oracle (aws_rds_oracle) - Connect and sync data from AWS Oracle
• Redshift (redshift/simple_redshift_connector) - Sync records from Redshift
• Redshift (Large Data Volume) (redshift/large_data_volume) - Sync large data volumes from Redshift
• Redshift (Using UNLOAD) (redshift/using_unload) - Sync data from Redshift using UNLOAD to S3
• Delta Sharing (delta_sharing) - Connect and sync data from Databricks Delta Sharing (now OpenSharing): An Open Protocol for Secure Data Sharing

Message Queues & Streaming

• Apache Pulsar (apache_pulsar) - Fetch data from Apache Pulsar topics with Reader API
• Google Cloud Pub/Sub (gcp_pub_sub) - Sync data from Google Cloud Pub/Sub
• RabbitMQ (rabbitmq) - Sync messages from RabbitMQ queues
• Solace (solace) - Sync messages from Solace queue

AI and Connector SDK

• Databricks Best Buy Retail Intelligence (databricks/databricks-fm-bestbuy-retail-intelligence) - Sync Best Buy product catalog data and enrich it with Databricks ai_query() retail intelligence for pricing, positioning, and sentiment analysis.
• Databricks CPSC Product Safety Intelligence (databricks/databricks-fm-cpsc-product-safety-intelligence) - Sync CPSC product recall data and enrich incidents with Databricks ai_query() multi-agent product safety analysis.
• Databricks FDA Drug Label Intelligence (databricks/databricks-fm-fda-drug-label-intelligence) - Sync OpenFDA drug label data and enrich package inserts with Databricks ai_query() analysis and optional Genie Space creation.
• Databricks FDA FAERS Pharmacovigilance Intelligence (databricks/databricks-fm-fda-faers-pv-intelligence) - Sync FDA FAERS adverse event reports and enrich serious events with Databricks ai_query() pharmacovigilance debate analysis.
• Databricks FHIR Healthcare Intelligence (databricks/databricks-fm-fhir-healthcare-intelligence) - Sync clinical data from a FHIR R4 server and enrich it with AI-powered hybrid analysis using Databricks ai_query().
• Databricks NOAA Weather Risk Intelligence (databricks/databricks-fm-noaa-weather-risk-intelligence) - Sync NOAA severe weather alerts and use Databricks ai_query() for agent-driven discovery and emergency risk analysis.
• Databricks SEC EDGAR Risk Intelligence (databricks/databricks-fm-sec-edgar-risk-intelligence) - Sync SEC EDGAR filings and XBRL financial facts, then enrich them with Databricks ai_query() credit risk intelligence.
• Databricks TVMaze Programming Intelligence (databricks/databricks-fm-tvmaze-programming-intelligence) - Sync TVMaze show metadata and enrich each show with Databricks ai_query() programming renewal debate analysis.
• Snowflake Cortex Clinical Trial Intelligence (snowflake_cortex/snowflake-cortex-code-clinical-trial-intelligence) - Sync ClinicalTrials.gov records and enrich them with Snowflake Cortex Agent clinical trial landscape intelligence.
• Snowflake Cortex NHTSA Safety Intelligence (snowflake_cortex/snowflake-cortex-code-nhtsa-safety-intelligence) - Sync NHTSA recalls, complaints, and vehicle specs, then use Snowflake Cortex Agent for vehicle safety discovery and analysis.
• Snowflake Cortex NVD CVE Threat Intelligence (snowflake_cortex/snowflake-cortex-code-nvd-cve-threat-intelligence) - Sync NVD CVE records and enrich vulnerabilities with Snowflake Cortex multi-agent threat intelligence.
• Snowflake Cortex Hacker News (snowflake_cortex/snowflake-cortex-hacker-news) - Sync Hacker News top stories and enrich them with Snowflake Cortex sentiment and topic classification.
• Snowflake Cortex Livestock Weather Intelligence (snowflake_cortex/snowflake-cortex-livestock-weather-intelligence) - Sync farm weather forecasts and enrich them with Snowflake Cortex livestock health risk assessments.

SaaS & APIs

• Amazon Video Central (amazon_video_central) - Sync report data from Amazon Video Central API
• Awardco (awardco) - Sync data from Awardco rewards platform
• Beehiiv (beehiiv) - Sync newsletter data from the beehiiv API, including publications, subscriptions, posts, email blasts, automations, and engagement metrics
• Better Stack (betterstack) - Sync uptime monitoring data from Better Stack
• Bright Data Web Scraper (bright_data_scrape) - Sync scraped web page content and extracted fields from the Bright Data Web Scraper API
• Bright Data Web Unlocker (bright_data_unlocker) - Sync unlocked web page content for one or more URLs from the Bright Data Web Unlocker API
• CallMiner (callminer) - Sync CallMiner Bulk Export data using OAuth2 authentication, export job polling, archive extraction, and per-data-type incremental state tracking
• Checkly (checkly) - Sync monitoring check data and analytics from Checkly
• Clerk (clerk) - Sync user data from Clerk authentication
• Common Paper (commonpaper) - Sync agreement data from Common Paper
• Courier (courier) - Sync notifications data from Courier multi-channel platform
• Customer Thermometer (customer_thermometer) - Sync customer feedback from Customer Thermometer
• DataCamp (data_camp) - Sync course catalog from DataCamp LMS
• Discord (discord) - Sync data from Discord
• Docusign eSignature (docusign) - Sync data from Docusign eSignature API
• Elastic Email (elastic_email) - Sync email marketing data from Elastic Email
• Federal Register (federal_register) - Sync rules, proposed rules, notices, and presidential documents from the Federal Register API
• Fleetio (fleetio) - Sync fleet management data from Fleetio
• FRED (fred) - Sync economic data from Federal Reserve Economic Data (FRED)
• GBIF (gbif) - Sync species occurrence records from the GBIF (Global Biodiversity Information Facility) API
• GitHub (github) - Sync repository data, commits, and pull requests from GitHub
• GitHub Repository Traffic (github_traffic) - Sync GitHub repository traffic data
• GLEIF (gleif) - Sync Legal Entity Identifier (LEI) reference data from the GLEIF API
• GNews (gnews) - Sync news articles from GNews API
• Google Trends (google_trends) - Sync search interest data from Google Trends
• Goshippo (goshippo) - Sync shipment data from Goshippo API
• Grey HR (grey_hr) - Sync HR data from greytHR API
• Gumroad (gumroad) - Sync sales, products, and subscribers from Gumroad
• Harness.io (harness_io) - Connect and sync data from Harness.io
• Healthchecks.io (healthchecks) - Sync health check monitoring from Healthchecks.io
• HubSpot (hubspot) - Sync event data from HubSpot
• Iterate (iterate) - Sync NPS survey data from Iterate REST API
• Keycloak (keycloak) - Sync IAM data from Keycloak Admin API
• LeaveDates (leavedates) - Sync leave report data from LeaveDates API
• MailerLite (mailerlite) - Sync email marketing data from MailerLite
• MasterTax (mastertax) - Sync data from MasterTax API
• MeiliSearch (meilisearch) - Sync index metadata and documents from MeiliSearch
• Microsoft Excel (microsoft_excel) - Sync data from Microsoft Excel files
• Microsoft Intune (microsoft_intune) - Retrieve managed devices from Microsoft Intune
• n8n (n8n) - Sync workflow automation data from n8n
• Netlify (netlify) - Sync sites, deploys, and forms from Netlify API
• News API (newsapi) - Sync news articles from NewsAPI
• NOAA (noaa) - Sync weather observations from National Weather Service
• NPPES NPI Registry (npi_registry) - Sync healthcare provider data from NPPES NPI Registry
• Accelo (oauth2_and_accelo_api_connector_multithreading_enabled) - Sync data from Accelo API with OAuth 2.0 and multithreading
• OData API (odata_api) - Sync data from OData APIs (versions 2 and 4)
• Oktopost (oktopost) - Sync social media exports from Oktopost BI API
• Open-Meteo Marine Weather (open_meteo_marine_weather) - Sync hourly and daily marine weather data (wave height, direction, period, swell, wind waves) from the Open-Meteo Marine Weather API
• Oura Ring (oura_ring) - Sync daily activity, sleep, readiness, stress, and heart rate data from the Oura Ring API v2.
• OWASP API Vulnerabilities (owasp_api_vulns) - Sync OWASP API vulnerability data from NVD 2.0
• Partech (Punchh) (partech) - Sync POS data from Partech (formerly Punchh)
• Pindrop (pindrop) - Sync nightly report data from Pindrop
• Prefect Cloud (prefect) - Sync workflow orchestration data from Prefect Cloud
• Prometheus (prometheus) - Sync metrics and time series from Prometheus
• Resend (resend) - Sync email data from Resend API
• Rillet (rillet) - Sync accounting data from Rillet.
• S3 CSV File Reader with Data Validation (s3_csv_validation) - Read and validate CSV files from Amazon S3
• SAM.gov (sam_gov) - Sync government contracting opportunities from SAM.gov
• SAP Ariba (sap_ariba) - Sync procurement data from SAP Ariba
• Sendcloud (sendcloud) - Sync shipment data from Sendcloud API
• Sensor Tower (sensor_tower) - Sync mobile app market intelligence from Sensor Tower
• SenSource (sensource) - Sync traffic and occupancy metrics from SenSource
• SharePoint Multi-Site (sharepoint_multi_site_connector) - Sync CSV and Excel file data from multiple SharePoint Online sites using the Microsoft Graph API, with support for multi-sheet workbooks, recursive folder traversal, and deletion handling.
• BAI2 SFTP (sftp_connector/bai2_sftp_connector) - Fetch BAI2-format cash management files from an SFTP server and load all transactions into a single destination table with incremental sync and structured ACH field parsing
• Fixed-Width SFTP (sftp_connector/fixed_width_sftp_connector) - Read 12 fixed-width files from 3 SFTP subdirectories (ELAN, CUP, LPL/DFM) into 12 destination tables with soft-delete purge logic and implied-decimal parsing
• Similarweb (similarweb) - Sync website performance metrics from SimilarWeb
• Smartsheet (smartsheets) - Sync sheets and reports from Smartsheets
• Snipe-IT (snipeitapp) - Sync IT asset management data from Snipe-IT
• StatusCake (status_cake) - Sync uptime monitoring from StatusCake
• SuiteDash (suitedash) - Sync CRM data from SuiteDash API
• Supabase (supabase) - Sync employee data from Supabase database
• Talon.One (talon_one) - Sync events data from Talon.One
• Temporal Cloud (temporal_cloud) - Sync workflow execution and schedule data from Temporal Cloud.
• Toast (toast) - Sync POS data from Toast
• Tulip Interfaces (tulip_interfaces) - Sync data from Tulip Tables
• Veeva Vault (Basic Authentication) (veeva_vault/basic_auth) - Authenticate to Veeva Vault with basic auth
• Veeva Vault (Session Authentication) (veeva_vault/session_id_auth) - Authenticate to Veeva Vault with session ID
• Vercel (vercel) - Sync deployment data from Vercel REST API
• Oracle WMS (wms_oracle) - Sync warehouse management data from Oracle WMS REST API with incremental sync, historical backfill, and pre-cursor drift detection across 26 entities.
• Weights & Biases (weights_and_biases) - Sync machine learning experiment tracking data from Weights & Biases, including projects, runs, and artifacts.
• Zigpoll (zigpoll) - Sync polling data from Zigpoll