当前位置：首页 > news >正文

pg_durable节点类型详解：SQL、HTTP、Sleep、Wait等核心操作全解析

news 2026/6/17 7:01:45

pg_durable节点类型详解：SQL、HTTP、Sleep、Wait等核心操作全解析

【免费下载链接】pg_durablePostgreSQL in-database durable execution项目地址: https://gitcode.com/GitHub_Trending/pg/pg_durable

pg_durable是PostgreSQL的in-database durable execution扩展，提供了强大的节点类型系统来构建可靠的工作流。本文将详细介绍SQL、HTTP、Sleep和Wait等核心节点类型的功能特性、使用场景和最佳实践，帮助新手用户快速掌握这一强大工具。

📊 什么是pg_durable节点类型？

在pg_durable中，节点是工作流的基本构建块，每种节点类型对应不同的执行逻辑。节点类型定义在docs/ARCHITECTURE.md中，主要包括SQL、HTTP、WAIT_*等类别，通过node_type字段标识。节点之间可以组合形成复杂的工作流图，实现条件分支、并行执行等高级逻辑。

💻 SQL节点：数据库操作的核心单元

SQL节点是pg_durable中最基础也最常用的节点类型，用于执行PostgreSQL查询并处理结果。

基本用法

-- df.sql()创建SQL节点 -- Returns: {"node_type":"SQL","query":"SELECT 1",...} SELECT df.sql('SELECT current_timestamp AS execution_time');

主要特性

支持任意有效的PostgreSQL查询语句
自动处理事务和错误恢复
结果可以被后续节点引用
定义在docs/nested-graph-design.md中的核心节点类型

使用场景

数据查询与处理
数据库表更新操作
事务管理
作为工作流的基础构建块

🌐 HTTP节点：连接外部系统的桥梁

HTTP节点允许工作流与外部HTTP服务进行通信，实现跨系统集成。

基本用法

-- 创建HTTP节点 SELECT df.http('{"url":"https://api.example.com/data","method":"GET"}');

主要特性

支持GET、POST等HTTP方法
可配置请求头和请求体
自动处理超时和重试
安全的URL访问控制机制

使用场景

调用外部API服务
触发webhook通知
从外部系统获取数据
与云服务集成（如Azure Functions）

⏱️ Wait节点：工作流中的时间控制

Wait系列节点用于在工作流中引入时间延迟或等待特定条件，主要包括WAIT_IDLE等类型。

基本特性

支持固定时间等待
可基于条件动态等待
不占用数据库连接资源
定义在docs/pg_durable_spec.md中

使用场景

实现定时任务
等待外部系统处理完成
控制工作流执行节奏
实现退避重试机制

🧩 节点组合与高级应用

pg_durable的强大之处在于能够将不同类型的节点组合使用，构建复杂的工作流逻辑。

顺序执行示例

-- 创建包含两个SQL节点的顺序执行 -- Returns: {"node_type":"THEN","left_node":{"node_type":"SQL","query":"SELECT 1"},"right_node":{"node_type":"SQL","query":"SELECT 2"}} SELECT df.then( df.sql('SELECT 1'), df.sql('SELECT 2') );