数据库节点

数据库节点是工作流与结构化数据存储系统之间的桥梁。它们允许您执行标准的数据库操作，将自动化流程中处理好的数据存入数据库，或从数据库中查询数据以供流程使用。
用途：

数据持久化：将自动化结果保存到数据库中，形成数据积累。
数据查询：从数据库中获取记录，作为自动化流程的输入数据。
系统集成：在不同的数据库系统之间同步和迁移数据。
操作自动化：自动执行常规的数据维护和更新任务。

PostgreSQL

节点用途：

在 TeGo-AI 工作流中直接读写 PostgreSQL 关系型数据库，完成数据持久化、查询、更新与删除。

使用场景：

数据查询： 根据用户 ID 查询订单并推送到 Slack 通知
数据写入： 将外部 API 获取的订单批量写入 PostgreSQL
定期任务： 每日把分析结果写回 BI 表供报表使用

节点参数：

参数名称	含义	格式/选项	示例
Operation	操作类型	`Execute Query` / `Insert` / `Update` / `Delete`	`Execute Query`
Query	SQL 语句，支持表达式占位符	字符串	`SELECT * FROM orders WHERE user_id = {{$json.userId}}`
Table	目标表名，Insert/Update/Delete 必填	字符串	`orders`
Columns	写入字段列表	字符串	`name/amount`
Values	写入值数组	字符串	`{{$json.name}}/{{$json.amount}}`
Credentials	连接凭据	字符串	`prod-pg`

配置示例：

场景： 根据用户 ID 查询订单
配置：

Operation: Execute Query
Query: SELECT * FROM orders WHERE user_id = {{$json.userId}}
Credentials: prod-pg

MySQL

节点用途：

连接 MySQL 数据库，执行任意 SQL，完成数据读写与事务处理。

使用场景：

数据写入：把表单提交数据实时写入 MySQL
定期任务：每日汇总用户活跃数并更新统计表
事务操作：一次性插入多条记录保证原子性

节点参数：

参数名称	含义 / 格式选项	示例
Operation	操作类型：Execute Query / Insert / Update / Delete	Insert
Query	SQL 语句，支持 ? 占位符	INSERT INTO users(name,email) VALUES(?,?)
Table	目标表名	users
Columns	字段列表：字段/字段	name/email
Values	对应值列表：值/值	{{$json.name}}/{{$json.email}}
Credentials	已保存的 MySQL 账户	analytics-db

配置示例：

场景：插入新用户
配置：

Operation: Insert
Table: users
Columns: name/email
Values: {{$json.name}}/{{$json.email}}
Credentials: analytics-db

Microsoft SQL Server

节点用途：

读写 MSSQL 数据库，支持 T-SQL 语法及事务。

使用场景：

数据同步：同步 ERP 订单到 MSSQL
存储过程：调用 usp_UpdateInventory 更新库存
批量更新：批量更新订单状态字段

节点参数：

参数名称	含义 / 格式选项	示例
Operation	操作类型：Execute Query / Insert / Update / Delete	Execute Query
Query	T-SQL 语句	EXEC usp_UpdateInventory @sku={{ $json.sku }}, @qty={{ $json.qty }}
Table	表名	inventory
Columns	字段列表：字段/字段	sku/qty
Values	值列表：值/值	{{$json.sku}}/{{$json.qty}}
Credentials	MSSQL 账户	erp-sql

配置示例：

场景：调用存储过程更新库存
配置：

Operation: Execute Query
Query: EXEC usp_UpdateInventory @sku={{ $json.sku }}, @qty={{ $json.qty }}
Credentials: erp-sql

SQLite

节点用途：

在本地或边缘设备使用轻量级 SQLite 文件数据库，零配置即可运行。

使用场景：

本地缓存：缓存 API 结果减少重复请求
IoT 记录：离线记录传感器数据
原型验证：桌面脚本快速原型验证

节点参数：

参数名称	含义 / 格式选项	示例
Operation	操作类型：Execute Query / Insert / Update / Delete	Insert
Query	SQL 语句	INSERT INTO logs(sensor_id,temp) VALUES(?,?)
Database Path	SQLite 文件路径	./data/sensors.db
Table	表名	logs
Columns	字段列表：字段/字段	sensor_id/temp
Values	值列表：值/值	{{$json.id}}/{{$json.temp}}

配置示例：

场景：离线记录温度数据
配置：

Operation: Insert
Database Path: ./data/sensors.db
Table: logs
Columns: sensor_id/temp
Values: {{$json.id}}/{{$json.temp}}

Redis

节点用途：

高速键值缓存、计数器、队列与发布订阅，毫秒级读写。

使用场景：

缓存：缓存用户 Token 减少数据库查询
计数器：统计 API 调用次数
队列：轻量级任务队列

节点参数：

参数名称	含义 / 格式选项	示例
Operation	操作类型：Set / Get / Incr / Del / Publish	Set
Key	键名	token:{{$json.userId}}
Value	键值	{{$json.accessToken}}
Expire	过期时间(秒)	3600
Credentials	Redis 账户	redis-prod

配置示例：

场景：缓存用户 Token 1 小时
配置：

Operation: Set
Key: token:{{$json.userId}}
Value: {{$json.accessToken}}
Expire: 3600
Credentials: redis-prod

Snowflake

节点用途：

云原生数据仓库，执行复杂分析 SQL 并高速返回结果。

使用场景：

数据查询：拉取昨日广告花费并推送邮件
数据写入：将转化事件批量写入 Snowflake
定期任务：每日跑 ETL 生成用户画像表

节点参数：

参数名称	含义 / 格式选项	示例
Operation	操作类型：Execute Query / Insert / Update / Delete	Execute Query
Query	SQL 语句	SELECT * FROM ads_cost WHERE date = CURRENT_DATE - 1
Warehouse	计算集群	COMPUTE_WH
Database	数据库	ANALYTICS
Schema	模式	PUBLIC
Credentials	Snowflake 账户	snowflake-prod

配置示例：

场景：查询昨日广告花费
配置：

Operation: Execute Query
Query: SELECT * FROM ads_cost WHERE date = CURRENT_DATE - 1
Warehouse: COMPUTE_WH
Database: ANALYTICS
Schema: PUBLIC
Credentials: snowflake-prod

MongoDB

节点用途：

文档型 NoSQL，支持灵活 JSON 结构及聚合管道。

使用场景：

数据查询：根据用户 ID 查询完整 JSON 档案
数据写入：将事件日志直接插入集合
聚合分析：使用聚合管道计算用户留存

节点参数：

参数名称	含义 / 格式选项	示例
Operation	操作类型：Find / Insert / Update / Aggregate	Find
Collection	集合名	users
Query	MongoDB 查询 JSON	{"userId": "{{$json.userId}}"}
Update	更新文档	{"$set": {"lastLogin": "{{$now}}"}}
Credentials	MongoDB 账户	mongo-prod

配置示例：

场景：查询用户档案
配置：

Operation: Find
Collection: users
Query: {"userId": "{{$json.userId}}"}
Credentials: mongo-prod

CrateDB

节点用途：

分布式 SQL 数据库，专为时序与搜索场景优化，兼容 PostgreSQL 协议。

使用场景：

数据写入：IoT 传感器数据高并发写入
数据查询：实时分析设备状态并触发告警
聚合分析：计算过去 5 分钟平均温度

节点参数：

参数名称	含义 / 格式选项	示例
Operation	操作类型：Execute Query / Insert / Update / Delete	Execute Query
Query	SQL 语句	SELECT AVG(temp) FROM sensors WHERE ts >= NOW() - INTERVAL '5 minutes'
Table	表名	sensors
Columns	字段列表：字段/字段	device_id/temp
Values	值列表：值/值	{{$json.device_id}}/{{$json.temp}}
Credentials	CrateDB 账户	cratedb-prod

配置示例：

场景：查询最近 5 分钟平均温度
配置：

Operation: Execute Query
Query: SELECT AVG(temp) FROM sensors WHERE ts >= NOW() - INTERVAL '5 minutes'
Credentials: cratedb-prod

TimescaleDB

节点用途：

基于 PostgreSQL 的时序数据库，支持自动分区与连续聚合。

使用场景：

数据写入：高并发写入服务器监控指标
数据查询：拉取过去 1 小时 CPU 使用率
连续聚合：自动生成每分钟 CPU 平均值

节点参数：

参数名称	含义 / 格式选项	示例
Operation	操作类型：Execute Query / Insert / Update / Delete	Execute Query
Query	SQL 语句	SELECT time_bucket('1 min', ts) AS minute, AVG(cpu) FROM metrics WHERE ts > NOW() - INTERVAL '1 hour' GROUP BY minute
Table	表名	metrics
Columns	字段列表：字段/字段	host/cpu
Values	值列表：值/值	{{$json.host}}/{{$json.cpu}}
Credentials	TimescaleDB 账户	tsdb-prod

配置示例：

场景：查询过去 1 小时 CPU 每分钟平均值
配置：

Operation: Execute Query
Query: SELECT time_bucket('1 min', ts) AS minute, AVG(cpu) FROM metrics WHERE ts > NOW() - INTERVAL '1 hour' GROUP BY minute
Credentials: tsdb-prod

QuestDB

节点用途：

高性能列式时序数据库，支持 Influx Line 协议，适合实时分析。

使用场景：

数据写入：金融行情数据高速追加
数据查询：实时查询最新成交价
批量导出：导出过去 1 小时行情 CSV

节点参数：

参数名称	含义 / 格式选项	示例
Operation	操作类型：Execute Query / Insert / Update / Delete	Execute Query
Query	SQL 语句	SELECT * FROM trades WHERE timestamp > NOW() - INTERVAL '1 hour'
Table	表名	trades
Columns	字段列表：字段/字段	symbol/price
Values	值列表：值/值	{{$json.symbol}}/{{$json.price}}
Credentials	QuestDB 账户	quest-prod

配置示例：

场景：查询过去 1 小时成交记录
配置：

Operation: Execute Query
Query: SELECT * FROM trades WHERE timestamp > NOW() - INTERVAL '1 hour'
Credentials: quest-prod

ClickHouse

节点用途：

开源列式 OLAP 数据库，秒级返回 PB 级聚合查询结果。

使用场景：

数据写入：批量写入广告点击事件
数据查询：实时统计广告点击率
物化视图：自动汇总每日收入

节点参数：

参数名称	含义 / 格式选项	示例
Operation	操作类型：Execute Query / Insert / Update / Delete	Execute Query
Query	SQL 语句	SELECT ad_id, count() AS clicks FROM clicks WHERE date = today() GROUP BY ad_id
Table	表名	clicks
Columns	字段列表：字段/字段	ad_id/timestamp
Values	值列表：值/值	{{$json.ad_id}}/{{$json.timestamp}}
Credentials	ClickHouse 账户	click-prod

配置示例：

场景：统计今日各广告点击量
配置：

Operation: Execute Query
Query: SELECT ad_id, count() AS clicks FROM clicks WHERE date = today() GROUP BY ad_id
Credentials: click-prod

Supabase

节点用途：

基于 PostgreSQL 的托管后端，即开即用，自带实时 API。

使用场景：

数据写入：前端表单直接插入 Supabase
数据查询：获取用户资料并渲染页面
实时订阅：监听新增订单触发通知

节点参数：

参数名称	含义 / 格式选项	示例
Operation	操作类型：Execute Query / Insert / Update / Delete	Insert
Table	表名	todos
Columns	字段列表：字段/字段	title/done
Values	值列表：值/值	{{$json.title}}/false
Credentials	Supabase 账户	supa-prod

配置示例：

场景：新增待办事项
配置：

Operation: Insert
Table: todos
Columns: title/done
Values: {{$json.title}}/false
Credentials: supa-prod

Cassandra

节点用途：

分布式宽列数据库，线性扩展，适合大规模写多读少场景。

使用场景：

数据写入：IoT 设备每秒万条写入
数据查询：按分区键快速读取历史状态
批量删除：TTL 到期自动清理旧数据

节点参数：

参数名称	含义 / 格式选项	示例
Operation	操作类型：Execute Query / Insert / Update / Delete	Insert
Query	CQL 语句	INSERT INTO sensor_data(device_id, ts, temp) VALUES(?,?,?)
Table	表名	sensor_data
Columns	字段列表：字段/字段	device_id/ts/temp
Values	值列表：值/值	{{$json.device_id}}/{{$json.ts}}/{{$json.temp}}
Credentials	Cassandra 账户	cass-prod

配置示例：

场景：写入传感器数据
配置：

Operation: Insert
Query: INSERT INTO sensor_data(device_id, ts, temp) VALUES(?,?,?)
Columns: device_id/ts/temp
Values: {{$json.device_id}}/{{$json.ts}}/{{$json.temp}}
Credentials: cass-prod

CouchDB

节点用途：

面向文档的 NoSQL，使用 JSON + HTTP API，支持离线同步。

使用场景：

数据写入：移动端离线记录同步到 CouchDB
数据查询：通过视图查询待同步文档
附件管理：上传图片并关联文档

节点参数：

参数名称	含义 / 格式选项	示例
Operation	操作类型：Get / Insert / Update / Delete	Insert
Database	数据库名	mobile_logs
Document	文档 JSON	{"type":"log","msg":"{{$json.msg}}"}
Document ID	可选，指定 ID	log_{{$json.deviceId}}_{{$now}}
Credentials	CouchDB 账户	couch-prod

配置示例：

场景：插入离线日志
配置：

Operation: Insert
Database: mobile_logs
Document: {"type":"log","msg":"{{$json.msg}}"}
Credentials: couch-prod

Db2

节点用途：

IBM 企业级关系型数据库，支持高级事务与 SQL PL。

使用场景：

数据查询：从 Db2 拉取客户主数据
数据写入：将订单结果回写核心系统
事务操作：多条更新一次性提交

节点参数：

参数名称	含义 / 格式选项	示例
Operation	操作类型：Execute Query / Insert / Update / Delete	Execute Query
Query	SQL 语句	SELECT * FROM customers WHERE cust_id = {{$json.custId}}
Table	表名	customers
Columns	字段列表：字段/字段	cust_name/cust_email
Values	值列表：值/值	{{$json.name}}/{{$json.email}}
Credentials	Db2 账户	db2-prod

配置示例：

场景：查询客户主数据
配置：

Operation: Execute Query
Query: SELECT * FROM customers WHERE cust_id = {{$json.custId}}
Credentials: db2-prod

DuckDB

节点用途：

嵌入式分析型数据库，零依赖、高性能，适合本地数据探索。

使用场景：

本地分析：快速分析 CSV/Parquet
原型验证：在笔记本上跑复杂 SQL 原型
轻量 ETL：把 DuckDB 结果导出为 Excel

节点参数：

参数名称	含义 / 格式选项	示例
Operation	操作类型：Execute Query / Insert / Update / Delete	Execute Query
Query	SQL 语句	SELECT * FROM read_csv_auto('data.csv') LIMIT 100
Table	表名	events
Columns	字段列表：字段/字段	event_type/value
Values	值列表：值/值	{{$json.type}}/{{$json.value}}
Credentials	DuckDB 账户	duck-prod

配置示例：

场景：快速预览 CSV 前 100 行
配置：

Operation: Execute Query
Query: SELECT * FROM read_csv_auto('data.csv') LIMIT 100
Credentials: duck-prod

etcd

节点用途：

分布式键值存储，用于配置中心与服务发现，高可用强一致。

使用场景：

配置读取：拉取最新灰度开关配置
配置写入：更新功能开关状态
服务发现：获取下游服务地址列表

节点参数：

参数名称	含义 / 格式选项	示例
Operation	操作类型：Get / Put / Delete	Get
Key	键名	/feature/flagX
Value	写入值，Put 必填	true
Credentials	etcd 账户	etcd-prod

配置示例：

场景：读取功能开关
配置：

Operation: Get
Key: /feature/flagX
Credentials: etcd-prod

InfluxDB

节点用途：

专为时序数据设计，支持高写入吞吐与类 SQL 查询。

使用场景：

数据写入：高并发写入服务器监控指标
数据查询：查询过去 1 小时 CPU 使用率
连续查询：自动降采样保留 7 天数据

节点参数：

参数名称	含义 / 格式选项	示例
Operation	操作类型：Execute Query / Insert / Delete	Insert
Query	InfluxQL 语句	SELECT mean("value") FROM "cpu" WHERE time > now() - 1h GROUP BY "host"
Measurement	表名	cpu
Tags	Tag 列表：tag/tag	host/region
Fields	Field 列表：field/field	value/load
Values	值列表：值/值	{{$json.value}}/{{$json.load}}
Credentials	InfluxDB 账户	influx-prod

配置示例：

场景：写入 CPU 指标
配置：

Operation: Insert
Measurement: cpu
Tags: host/region
Fields: value/load
Values: {{$json.value}}/{{$json.load}}
Credentials: influx-prod

MariaDB

节点用途：

MySQL 兼容的开源关系型数据库，企业级特性丰富。

使用场景：

数据写入：博客评论实时写入 MariaDB
数据查询：拉取最新文章列表返回前端
批量更新：更新文章阅读数

节点参数：

参数名称	含义 / 格式选项	示例
Operation	操作类型：Execute Query / Insert / Update / Delete	Insert
Query	SQL 语句	INSERT INTO comments(post_id,author,content) VALUES(?,?,?)
Table	表名	comments
Columns	字段列表：字段/字段	post_id/author/content
Values	值列表：值/值	{{$json.postId}}/{{$json.author}}/{{$json.content}}
Credentials	MariaDB 账户	mariadb-prod

配置示例：

场景：插入评论
配置：

Operation: Insert
Table: comments
Columns: post_id/author/content
Values: {{$json.postId}}/{{$json.author}}/{{$json.content}}
Credentials: mariadb-prod

Oracle Database

节点用途：

企业级关系型数据库，支持复杂事务、PL/SQL 与高级分析。

使用场景：

数据查询：从 ERP 拉取订单明细
数据写入：将财务结果回写 Oracle
存储过程：调用 PL/SQL 生成月结报表

节点参数：

参数名称	含义 / 格式选项	示例
Operation	操作类型：Execute Query / Insert / Update / Delete	Execute Query
Query	SQL 或 PL/SQL 语句	SELECT * FROM oe_order_headers_all WHERE order_number = {{$json.orderNo}}
Table	表名	oe_order_headers_all
Columns	字段列表：字段/字段	order_number/status
Values	值列表：值/值	{{$json.orderNo}}/{{$json.status}}
Credentials	Oracle 账户	oracle-prod

配置示例：

场景：查询订单明细
配置：

Operation: Execute Query
Query: SELECT * FROM oe_order_headers_all WHERE order_number = {{$json.orderNo}}
Credentials: oracle-prod

PouchDB

节点用途：

浏览器与移动端离线数据库，可同步 CouchDB，支持离线优先应用。

使用场景：

离线存储：移动端离线保存表单数据
数据同步：恢复网络后自动同步到 CouchDB
本地查询：离线搜索历史记录

节点参数：

参数名称	含义 / 格式选项	示例
Operation	操作类型：Get / Put / Remove / Sync	Put
Database	本地数据库名	forms
Document	文档 JSON	{"type":"form","title":"{{$json.title}}"}
Document ID	可选，指定 ID	form_{{$json.id}}
Remote Database	远程同步 URL	https://couch.example.com/forms
Credentials	CouchDB 账户	couch-prod

配置示例：

场景：离线保存表单
配置：

Operation: Put
Database: forms
Document: {"type":"form","title":"{{$json.title}}"}
Remote Database: https://couch.example.com/forms
Credentials: couch-prod

Presto

节点用途：

分布式 SQL 查询引擎，跨 Hadoop/S3/关系型数据库联邦查询。

使用场景：

联邦查询：跨 MySQL 与 S3 联合分析
即席分析：数据科学家快速探索多源数据
报表加速：生成每日综合报表

节点参数：

参数名称	含义 / 格式选项	示例
Operation	操作类型：Execute Query / Insert / Delete	Execute Query
Query	Presto SQL 语句	SELECT * FROM mysql.db.orders o JOIN s3.events e ON o.id = e.order_id
Catalog	数据源 Catalog	mysql
Schema	数据库/模式	db
Credentials	Presto 账户	presto-prod

配置示例：

场景：跨 MySQL 与 S3 联合查询
配置：

Operation: Execute Query
Query: SELECT * FROM mysql.db.orders o JOIN s3.events e ON o.id = e.order_id
Catalog: mysql
Schema: db
Credentials: presto-prod

RavenDB

节点用途：

.NET 生态的文档型 NoSQL，支持 ACID 事务与全文检索。

使用场景：

数据写入：保存电商订单文档
数据查询：全文搜索商品描述
事务更新：更新库存并记录日志

节点参数：

参数名称	含义 / 格式选项	示例
Operation	操作类型：Load / Store / Query / Delete	Store
Collection	集合名	orders
Document	文档 JSON	{"customer":"{{$json.customer}}","total":{{$json.total}}}
Document ID	可选，指定 ID	orders/{{$json.orderId}}
Credentials	RavenDB 账户	raven-prod

配置示例：

场景：存储订单文档
配置：

Operation: Store
Collection: orders
Document: {"customer":"{{$json.customer}}","total":{{$json.total}}}
Credentials: raven-prod

Redshift

节点用途：

AWS 托管的 PB 级数据仓库，支持复杂 SQL 与并发查询。

使用场景：

数据查询：拉取过去 7 天广告转化数据
数据写入：将每日汇总表批量 COPY 到 Redshift
报表生成：生成月度收入报表

节点参数：

参数名称	含义 / 格式选项	示例
Operation	操作类型：Execute Query / Insert / Update / Delete	Execute Query
Query	SQL 语句	SELECT campaign, SUM(revenue) FROM fact_sales WHERE date BETWEEN '{{$json.start}}' AND '{{$json.end}}' GROUP BY campaign
Table	表名	fact_sales
Columns	字段列表：字段/字段	campaign/revenue
Values	值列表：值/值	{{$json.campaign}}/{{$json.revenue}}
Credentials	Redshift 账户	redshift-prod

配置示例：

场景：查询广告收入
配置：

Operation: Execute Query
Query: SELECT campaign, SUM(revenue) FROM fact_sales WHERE date BETWEEN '{{$json.start}}' AND '{{$json.end}}' GROUP BY campaign
Credentials: redshift-prod

ScyllaDB

节点用途：

C++ 重写的 Cassandra 兼容数据库，提供更低延迟与更高吞吐。

使用场景：

数据写入：实时写入游戏玩家事件
数据查询：按玩家 ID 拉取排行榜
批量删除：清理过期事件 TTL

节点参数：

参数名称	含义 / 格式选项	示例
Operation	操作类型：Execute Query / Insert / Update / Delete	Insert
Query	CQL 语句	INSERT INTO player_events(player_id, ts, score) VALUES(?,?,?)
Table	表名	player_events
Columns	字段列表：字段/字段	player_id/ts/score
Values	值列表：值/值	{{$json.playerId}}/{{$json.ts}}/{{$json.score}}
Credentials	ScyllaDB 账户	scylla-prod

配置示例：

场景：写入玩家事件
配置：

Operation: Insert
Query: INSERT INTO player_events(player_id, ts, score) VALUES(?,?,?)
Columns: player_id/ts/score
Values: {{$json.playerId}}/{{$json.ts}}/{{$json.score}}
Credentials: scylla-prod

AWS S3

节点用途：

在 TeGo-AI 工作流中对 Amazon S3 进行文件上传、下载、列举与删除操作。

使用场景：

文件上传：将生成的报表上传到 S3 供下载
文件下载：拉取 S3 原始日志进行解析
列举文件：每日列出备份目录并发送清单邮件

节点参数：

参数名称	含义 / 格式选项	示例
Operation	操作类型：Upload / Download / List / Delete	Upload
Bucket	S3 存储桶名称	my-reports
Key	对象键（文件名）	daily-{{$now}}.csv
File Selector	要上传的二进制文件	{{$binary.report}}
Region	区域代码	ap-northeast-1
Credentials	AWS 账户凭据	aws-prod

配置示例：

场景：上传 CSV 报表
配置：

Operation: Upload
Bucket: my-reports
Key: daily-{{$now}}.csv
File Selector: {{$binary.report}}
Credentials: aws-prod

Google Cloud Storage

节点用途：

读写 Google Cloud Storage，支持公开/私有对象管理及签名 URL。

使用场景：

文件上传：将 PDF 发票上传到 GCS 并生成公开链接
文件下载：拉取用户头像用于重处理
生命周期：根据前缀批量删除30天前的文件

节点参数：

参数名称	含义 / 格式选项	示例
Operation	操作类型：Upload / Download / List / Delete	Upload
Bucket	存储桶名称	invoices-pdf
Object Name	对象名称	{{$json.invoiceId}}.pdf
File Selector	上传文件	{{$binary.invoice}}
Credentials	GCP 凭据	gcp-prod

配置示例：

场景：上传发票 PDF
配置：

Operation: Upload
Bucket: invoices-pdf
Object Name: {{$json.invoiceId}}.pdf
File Selector: {{$binary.invoice}}
Credentials: gcp-prod

Microsoft OneDrive

节点用途：

在 TeGo-AI 中与 OneDrive 及 SharePoint 文件互通。

使用场景：

文件上传：将日报同步到 OneDrive 指定文件夹
文件下载：拉取 Excel 模板填充后回传
共享链接：创建只读共享链接给客户

节点参数：

参数名称	含义 / 格式选项	示例
Operation	操作类型：Upload / Download / List / Delete	Upload
Drive	驱动类型：me / site	me
Parent Item ID	目标文件夹 ID	01ABCDEF123
File Name	文件名	report.xlsx
File Selector	文件二进制	{{$binary.report}}
Credentials	Microsoft 账户	ms365-prod

配置示例：

场景：上传日报到个人 OneDrive
配置：

Operation: Upload
Drive: me
Parent Item ID: 01ABCDEF123
File Name: report.xlsx
File Selector: {{$binary.report}}
Credentials: ms365-prod

Dropbox

节点用途：

与 Dropbox 个人或团队空间交互，支持文件/文件夹操作。

使用场景：

备份：将数据库快照上传到 Dropbox
共享：生成共享链接发送给外部合作方
下载：拉取模板文件进行数据填充

节点参数：

参数名称	含义 / 格式选项	示例
Operation	操作类型：Upload / Download / List / Delete	Upload
Path	目标路径	/backups/db-{{$now}}.sql
File Selector	文件二进制	{{$binary.dump}}
Credentials	Dropbox 账户	dropbox-prod

配置示例：

场景：上传数据库备份
配置：

Operation: Upload
Path: /backups/db-{{$now}}.sql
File Selector: {{$binary.dump}}
Credentials: dropbox-prod

FTP

节点用途：

通过标准 FTP 协议与远程服务器传输文件。

使用场景：

文件上传：将 CSV 推送到客户 FTP 目录
文件下载：拉取 ERP 生成的 XML 订单文件
定期备份：每日打包日志并上传

节点参数：

参数名称	含义 / 格式选项	示例
Operation	操作类型：Upload / Download / List / Delete	Upload
Path	远程路径	/uploads/
File Selector	本地文件	{{$binary.data}}
File Name	文件名	orders.csv
Credentials	FTP 账户	ftp-legacy

配置示例：

场景：上传 CSV 到客户服务器
配置：

Operation: Upload
Path: /uploads/
File Selector: {{$binary.data}}
File Name: orders.csv
Credentials: ftp-legacy

SFTP

节点用途：

通过 SSH 加密通道传输文件，保障数据安全。

使用场景：

安全备份：把财务文件加密上传到 SFTP
下载对账：拉取银行提供的加密对账文件
公钥认证：使用密钥免密登录

节点参数：

参数名称	含义 / 格式选项	示例
Operation	操作类型：Upload / Download / List / Delete	Download
Path	远程文件路径	/outbox/reconcile.csv
File Selector	下载后保存的字段	{{$binary.reconcile}}
Credentials	SFTP 账户	sftp-bank

配置示例：

场景：下载对账文件
配置：

Operation: Download
Path: /outbox/reconcile.csv
Credentials: sftp-bank

Slack

节点用途：

在频道或私聊发送消息、上传文件、调用 API。

使用场景：

消息推送：订单完成后自动通知运营频道
文件分享：把日报 PDF 上传到 Slack
交互式：触发工作流按钮收集用户反馈

节点参数：

参数名称	含义 / 格式选项	示例
Operation	操作类型：Post / Upload / Get	Post
Channel	频道或用户 ID	#orders
Text	消息文本	订单 {{$json.orderId}} 已完成，金额 {{$json.amount}}
File Selector	附件（可选）	{{$binary.report}}
Credentials	Slack 账户	slack-prod

配置示例：

场景：发送订单完成通知
配置：

Operation: Post
Channel: #orders
Text: 订单 {{$json.orderId}} 已完成，金额 {{$json.amount}}
Credentials: slack-prod

Discord

节点用途：

向 Discord 服务器频道或用户发送消息。

使用场景：

实时告警：服务异常时推送至 DevOps 频道
社区运营：每日自动发送活动提醒
富文本：嵌入图片与按钮交互

节点参数：

参数名称	含义 / 格式选项	示例
Operation	操作类型：Send Message / Send Embed / Delete Message	Send Message
Channel	频道 ID	123456789012345678
Content	消息内容	系统将于 2:00 AM 维护，请注意！
Credentials	Discord 账户	discord-bot

配置示例：

场景：发送维护通知
配置：

Operation: Send Message
Channel: 123456789012345678
Content: 系统将于 2:00 AM 维护，请注意！
Credentials: discord-bot

Microsoft Teams

节点用途：

向 Teams 频道或聊天发送消息、卡片或文件。

使用场景：

审批通知：审批通过后自动 @ 相关人
文件推送：将周报发送到 Teams 频道
互动卡片：创建带按钮的任务卡片

节点参数：

参数名称	含义 / 格式选项	示例
Operation	操作类型：Send Message / Send Adaptive Card	Send Message
Team	团队 ID	aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb
Channel	频道 ID	19:aaaaaaaa@thread.tacv2
Message	消息文本	项目 A 已上线，请查看最新版本
Credentials	Microsoft 账户	teams-prod

配置示例：

场景：发送项目上线通知
配置：

Operation: Send Message
Team: aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb
Channel: 19:aaaaaaaa@thread.tacv2
Message: 项目 A 已上线，请查看最新版本
Credentials: teams-prod

Gmail

节点用途：

发送、搜索、标记或删除 Gmail 邮件。

使用场景：

自动发送：每日销售汇总自动邮件给老板
邮件搜索：拉取带“发票”标签的邮件解析 PDF
草稿保存：先将模板保存为草稿再人工确认

节点参数：

参数名称	含义 / 格式选项	示例
Operation	操作类型：Send / Get / Delete / Reply	Send
To	收件人邮箱	boss@example.com
Subject	邮件主题	昨日销售汇总
Body	邮件正文（支持 HTML）	总额：{{$json.total}}
Attachments	附件列表	{{$binary.report}}
Credentials	Gmail 账户	gmail-prod

配置示例：

场景：发送销售汇总邮件
配置：

Operation: Send
To: boss@example.com
Subject: 昨日销售汇总
Body: <h3>总额：{{$json.total}}</h3>
Attachments: {{$binary.report}}
Credentials: gmail-prod

Microsoft Outlook

节点用途：

通过 Outlook 发送、读取、删除邮件或处理日历。

使用场景：

会议邀请：自动发送会议邀请给参会人
邮件通知：系统异常时发送告警邮件
日历查询：拉取下周空闲时段

节点参数：

参数名称	含义 / 格式选项	示例
Operation	操作类型：Send Email / Get Calendar / Create Event	Send Email
To	收件人	team@example.com
Subject	主题	每日站会提醒
Body	邮件正文	请准备昨日进展更新
Credentials	Microsoft 账户	outlook-prod

配置示例：

场景：发送站会提醒
配置：

Operation: Send Email
To: team@example.com
Subject: 每日站会提醒
Body: 请准备昨日进展更新
Credentials: outlook-prod

Twilio

节点用途：

发送短信、彩信或语音呼叫。

使用场景：

短信验证：发送登录验证码
订单通知：发货后自动短信告知客户
语音播报：余额不足自动语音提醒

节点参数：

参数名称	含义 / 格式选项	示例
Operation	操作类型：Send SMS / Send MMS / Make Call	Send SMS
From	Twilio 号码	+12065550100
To	接收号码	{{$json.phone}}
Message	短信内容	您的验证码是 123456，10分钟内有效
Credentials	Twilio 账户	twilio-prod

配置示例：

场景：发送验证码
配置：

Operation: Send SMS
From: +12065550100
To: {{$json.phone}}
Message: 您的验证码是 123456，10分钟内有效
Credentials: twilio-prod

WhatsApp Business Cloud

节点用途：

通过 Meta 官方 API 发送 WhatsApp 模板消息。

使用场景：

订单确认：发送订单成功模板消息
物流通知：推送包裹已发货模板
客服：根据关键字回复图文卡片

节点参数：

参数名称	含义 / 格式选项	示例
Operation	操作类型：Send Template / Send Text / Send Media	Send Template
Phone Number ID	WhatsApp 号码 ID	123456789012345
To	接收号码	{{$json.phone}}
Template Name	模板名称	order_confirmation
Language Code	语言代码	en_US
Parameters	模板变量值	{{$json.orderId}}/{{$json.total}}
Credentials	Meta 账户	whatsapp-prod

配置示例：

场景：发送订单确认模板
配置：

Operation: Send Template
Phone Number ID: 123456789012345
To: {{$json.phone}}
Template Name: order_confirmation
Language Code: en_US
Parameters: {{$json.orderId}}/{{$json.total}}
Credentials: whatsapp-prod

节点用途：

向 Telegram 用户、群组或频道发送文本、文件或轮询。

使用场景：

监控告警：服务器宕机立即推送群聊
文件推送：发送每日 PDF 报表到频道
Bot 互动：创建带按钮的投票

节点参数：

参数名称	含义 / 格式选项	示例
Operation	操作类型：Send Message / Send Photo / Send Document	Send Message
Chat ID	目标聊天 ID	-1001234567890
Text	消息内容	系统 CPU 使用率超过 90%
Parse Mode	解析模式：Markdown / HTML	Markdown
Credentials	Telegram Bot Token	telegram-bot

配置示例：

场景：发送告警消息
配置：

Operation: Send Message
Chat ID: -1001234567890
Text: 系统 CPU 使用率超过 90%
Parse Mode: Markdown
Credentials: telegram-bot

Facebook Graph API

节点用途：

调用 Facebook Graph API，实现帖子、评论、广告等操作。

使用场景：

发布帖子：自动发布新品到 Facebook 页面
评论回复：对负面评论自动回复
广告数据：拉取广告成效数据到 BI

节点参数：

参数名称	含义 / 格式选项	示例
Operation	HTTP 方法：GET / POST / DELETE	POST
Endpoint	API 路径	/{page-id}/posts
Parameters	查询或表单参数	message=新品上线&link={{$json.url}}
Credentials	Facebook 账户	fb-prod

配置示例：

场景：发布页面帖子
配置：

Operation: POST
Endpoint: /{page-id}/posts
Parameters: message=新品上线&link={{$json.url}}
Credentials: fb-prod

Twitter

节点用途：

发送推文、上传媒体、搜索或删除推文。

使用场景：

自动推文：新品上线自动发 Twitter
舆情监控：搜索品牌关键词并统计情感
媒体上传：发带图的促销推文

节点参数：

参数名称	含义 / 格式选项	示例
Operation	操作类型：Create / Search / Delete	Create
Text	推文内容	🎉 新品上线！链接 {{$json.url}}
Media IDs	媒体 ID 列表（可选）	123456789012345678
Credentials	Twitter 账户	twitter-prod

配置示例：

场景：发布新品推文
配置：

Operation: Create
Text: 🎉 新品上线！链接 {{$json.url}}
Credentials: twitter-prod

节点用途：

发布个人或公司动态，管理广告与消息。

使用场景：

内容营销：自动发布公司新闻到 LinkedIn
人才招聘：发布职位信息并收集简历
数据同步：同步招聘广告点击数据

节点参数：

参数名称	含义 / 格式选项	示例
Operation	操作类型：Create Post / Get Profile	Create Post
Author	作者 URN	urn:li:person:123ABC
Text	动态内容	我们发布了新的白皮书，点击阅读！
Visibility	可见范围：PUBLIC / CONNECTIONS	PUBLIC
Credentials	LinkedIn 账户	linkedin-prod

配置示例：

场景：发布公司动态
配置：

Operation: Create Post
Author: urn:li:person:123ABC
Text: 我们发布了新的白皮书，点击阅读！
Visibility: PUBLIC
Credentials: linkedin-prod

Instagram Graph API

节点用途：

发布照片、视频到 Instagram Business 帐号，获取媒体洞察。

使用场景：

内容发布：新品图集自动发布到 IG
洞察拉取：获取帖子互动数据
故事发布：上传限时动态

节点参数：

参数名称	含义 / 格式选项	示例
Operation	操作类型：Create Media / Publish Media / Get Insights	Create Media
Image URL	图片地址	https://example.com/image.jpg
Caption	帖子文案	探索我们的最新系列！#新品
Access Token	Instagram 访问令牌	{{$secrets.igToken}}
Credentials	Facebook 账户	ig-prod

配置示例：

场景：发布图片帖子
配置：

Operation: Create Media
Image URL: https://example.com/image.jpg
Caption: 探索我们的最新系列！#新品
Credentials: ig-prod

数据库节点

PostgreSQL

MySQL

Microsoft SQL Server

SQLite

Redis

Snowflake

MongoDB

CrateDB

TimescaleDB

QuestDB

ClickHouse

Supabase

Cassandra

CouchDB

Db2

DuckDB

etcd

InfluxDB

MariaDB

Oracle Database

PouchDB

Presto

RavenDB

Redshift

ScyllaDB

AWS S3

Google Cloud Storage

Microsoft OneDrive

Dropbox

FTP

SFTP

Slack

Discord

Microsoft Teams

Gmail

总额：{{$json.total}}

Microsoft Outlook

Twilio

WhatsApp Business Cloud

Telegram

Facebook Graph API

Twitter

LinkedIn

Instagram Graph API