Stream data from MySQL to Amazon SNS

Designed for high-throughput data pipelines, the Estuary MySQL connector captures every insert, update, and delete in real time using Change Data Capture (CDC). It reads from MySQL binary logs to ensure low-latency streaming and exactly-once delivery into Estuary collections. The connector works across self-hosted, RDS, Aurora, Cloud SQL, and Azure Database for MySQL environments with secure options like SSH tunneling and SSL.

• Continuous CDC streaming from MySQL binlogs
• Works with managed and on-prem MySQL instances
• Supports backfill for complete initial syncs
• Handles time zones and schema discovery automatically
• Secure connections via SSH or SSL

The Amazon SNS materialization connector in Estuary publishes documents from Estuary collections to Amazon Simple Notification Service (SNS) topics. It can continuously deliver data from real-time or batch pipelines into SNS for event-driven applications, notifications, and downstream AWS workflows.

• Publishes Estuary collection documents directly to Amazon SNS topics
• One SNS event is published for every document processed from the source collection
• Delta-update semantics only, since SNS does not store rows or support merge-based updates
• Supports standard and FIFO SNS topics, with FIFO topic names ending in .fifo
• Multiple Estuary collections can be mapped to SNS topics using separate bindings
• Configurable AWS region for the SNS service
• AWS Access Key authentication using an Access Key ID and Secret Access Key
• AWS IAM role authentication for role-based access
• Custom AWS endpoint support for compatible services such as LocalStack

Because Amazon SNS is an event-streaming system rather than a database, Estuary does not merge or update previously published records. Every document flowing through the materialization results in a new event being published to the configured SNS topic.