Ingest MQTT Data into PostgreSQL | EMQX Docs

Skip to content

Main Navigationemqx.com

English

English

Appearance

Sidebar Navigation

EMQX Overview

What's New

Feature Comparison

Get Started

Operating Limitations

FAQ

Concept FAQs

Deployment FAQs

Feature FAQs

Usage FAQs

Technical Support

Installation and Deployment

Installation Guide

Docker

Debian

Ubuntu

CentOS/RHEL

macOS

Kubernetes

EMQX Operator

Install Operator and Deploy EMQX

Deploy EMQX on AWS

Deploy EMQX on Google cloud

Deploy EMQX on Azure

Manage EMQX Cluster

Configure License (Enterprise)

Enable TLS in EMQX

Change EMQX Configurations

Enable Core + Replicant Cluster

Enable Persistence

Access EMQX Cluster by LoadBalancer

Configure Blue-Green Upgrade

Collect EMQX Logs

Change EMQX Log Level

Monitor EMQX Cluster

Load Balance EMQX Cluster

Deploy EMQX Cluster in k8s with Restricted Access

API Reference

EMQX Helm Chart

Work with License

Upgrade Guide

Rolling Upgrade

Upgrade EMQX Cluster from 4.4 to 5.x

Upgrade EMQX on Kubernetes

Developer Guide

Publish/Subscribe

MQTT Core Concepts

Test with MQTT Clients

MQTT Shared Subscription

MQTT Retained Message

MQTT Will Message

Exclusive Subscription

Delayed Publish

Auto Subscribe

Topic Rewrite

Wildcard Subscription

MQTT Durable Sessions

Client SDK

Connect via C SDK

Connect via Java SDK

Connect via Go SDK

Connect via Python SDK

Connect via JavaScript SDK

REST API

EMQX Enterprise API Docs

EMQX Clustering

Cluster Architecture

Create and Manage Cluster

Cluster Security

Configure Load Balancer

Load Balance EMQX Cluster with NGINX

Load Balance EMQX Cluster with HAProxy

Node Evacuation and Cluster Load Rebalancing

Performance and Tuning

Performance Tuning (Linux)

Performance Test with eMQTT-Bench

Test Scenarios and Results for Reference

Security Guide

Network and TLS

Enable SSL/TLS Connection

Client TLS Connection Code Examples

Obtain SSL/TLS Certificates

CRL Check

OCSP Stapling

Authentication

X.509 Certificate Authentication

JWT Authentication

Password-Based Authentication

Use Built-in Database

Integrate with MySQL

Integrate with MongoDB

Integrate with PostgreSQL

Integrate with Redis

Integrate with LDAP

Use HTTP Service

MQTT 5.0 Enhanced Authentication - SCRAM

REST API-Based MQTT 5.0 SCRAM Authentication

MQTT 5.0 Enhanced Authentication - Kerberos

Client-Info Authentication

PSK Authentication

Use HTTP API to Manage User Data

Access Control List

Authorization

Use ACL File

Use Built-in Database

Integrate with MySQL

Integrate with MongoDB

Integrate with PostgreSQL

Integrate with Redis

Integrate with LDAP

Use HTTP Service

Banned Clients

Flapping Detect

Rule Engine

Create Rules

Rule SQL Reference

Data Sources and Fields

Built-in SQL Functions

jq Functions

Smart Data Hub

Schema Registry

Schema Registry Example - Avro

Schema Registry Example - Protobuf

Schema Registry Example - External HTTP Server

Sparkplug B

Schema Validation

Message Transformation

Flow Designer

LLM-Based MQTT Data Processing

Quick Start: Create a Flow Using OpenAI Node

Quick Start: Create a Flow Using Anthropic Node

Quick Start: Create a Flow Using Gemini Node

Data Integration

Connector

Webhook

AlloyDB

Apache Doris

Apache Kafka

Apache IoTDB

Apache Pulsar

AWS Kinesis

AWS Redshift

AWS S3

AWS S3 Tables

Azure Blob Storage

Azure Event Hubs

BigQuery

Cassandra

ClickHouse

CockroachDB

Confluent

Couchbase

Datalayers

Disk Log

DynamoDB

Elasticsearch

GCP PubSub

GreptimeDB

HTTP Server

InfluxDB

Lindorm

Microsoft SQL Server

MongoDB

MQTT

MySQL

OpenTSDB

Oracle Database