跳到主要内容

PostgreSQL

设备、标签、用户、工作流等有相互关系且数量不多的数据都存放在这里。 需要连接、约束、事务的查询都在这一侧。

项目值
端口5432
主数据库pp
其他数据库temporal · temporal_visibility · kestra · hive-metastore-230
账户plantpulse
认证scram-sha-256

连接​

docker exec -it plantpulse-datalake pd node psql

如果要只执行一条命令：

docker exec plantpulse-datalake pd node psql -c "SELECT 1;"

如果使用浏览器，请使用 数据网关控制台 —— 它附带权限和审计功能。

示例​

当前有哪些表​

\dt                                    -- psql 메타명령
-- 또는 표준 SQL 로
SELECT table_name FROM information_schema.tables
 WHERE table_schema = 'public' ORDER BY 1;

设备及其标签数量​

SELECT e.equipment_id, e.equipment_name, count(t.tag_id) AS tags
FROM tm_equipment e
LEFT JOIN tm_tag t ON t.equipment_id = e.equipment_id
GROUP BY e.equipment_id, e.equipment_name
ORDER BY tags DESC
LIMIT 20;

各表大小——哪些在膨胀​

SELECT relname AS table,
       pg_size_pretty(pg_total_relation_size(relid)) AS size
FROM pg_catalog.pg_statio_user_tables
ORDER BY pg_total_relation_size(relid) DESC
LIMIT 15;

当前运行中的慢查询​

SELECT pid, now() - query_start AS elapsed, state, left(query, 80) AS query
FROM pg_stat_activity
WHERE state <> 'idle' AND now() - query_start > interval '5 seconds'
ORDER BY elapsed DESC;

复制是否跟上​

SELECT client_addr, state, sent_lsn, replay_lsn,
       pg_wal_lsn_diff(sent_lsn, replay_lsn) AS lag_bytes
FROM pg_stat_replication;

注意事项​

  • 🔴 请不要在这里查找时序数据。 标签值存储在 Aster TSDB 中 → CQL。
  • 角色密码每次启动时会根据 sidecar 值自动校准（ALTER ROLE，幂等操作）。如果要更改账户密码，请参阅 更改密码/API 密钥。
  • hive-metastore-230 是 Spark 和 Hive 使用的元存储。请勿手动修改。

相关文档​