触发器节点

触发器(Triggers)节点是整个自动化工作流的起点或开关。它们的主要职责是监听和等待特定事件的发生,一旦该事件发生,就会自动触发后续的工作流执行。可以把它们想象成自动化流程的"哨兵"或"启动按钮"。
用途:

  • 自动化启动:消除了手动启动流程的需要,实现真正的全自动化。
  • 事件驱动:让您的工作流能够对外部变化(如新邮件、新订单、定时器、Web 请求)做出实时反应。
  • 多样化监听:支持多种事件类型,包括定时调度、Web 请求、应用特定事件(如新消息、新记录)等。

Schedule

节点用途:

  • 用于按照预设的时间计划(如特定时间点、日期或周期)自动触发工作流的执行。

使用场景:

  • 定时任务:每天凌晨执行数据备份、每周发送统计报告、每月清理日志。
  • 周期性操作:每隔一段时间执行一次任务,如每 30 分钟检查一次新订单。
  • 计划性触发:在特定日期和时间触发流程,如节假日自动发送祝福消息。

节点参数:

参数名称 含义 格式/选项 示例
Schedule Type 调度类型 Cron / Every Minute / Every Hour / Every Day / Every Week / Every Month Every Day
Cron Expression Cron 表达式,定义执行时间规则 字符串(Cron 格式) 0 9 * * 1 (每周一 9 点)
Timezone 时区设置 时区字符串 Asia/Shanghai
Start Time 开始执行时间 日期时间 2023-10-01T00:00:00
End Time 结束执行时间 日期时间 2023-12-31T23:59:59

配置示例:

  • 场景:每天上午 10 点触发工作流执行。
  • 配置
Schedule Type: Every Day
Cron Expression: (留空,因已选 Every Day)
Timezone: Asia/Shanghai
Start Time: (可选)
End Time: (可选)

Webhook

节点用途:

  • 提供一个可由外部系统通过HTTP请求调用的URL,用于接收数据并触发工作流执行。

使用场景:

  • 实时数据接收: 接收来自第三方应用的通知(如支付回调、表单提交、消息推送)。
  • API集成: 作为API端点,允许其他系统通过POST/GET请求触发自动化流程。
  • 事件驱动: 响应Web事件,如GitHub Webhook、Slack Slash Command等。

节点参数:

参数名称 含义 格式/选项 示例
HTTP Method 接受的HTTP方法 GET / POST / PUT / DELETE POST
Path Webhook路径后缀 字符串 my-webhook
Response Mode 响应模式 Response Node (由后续节点响应) / On Received (立即响应) On Received
Response Code 立即响应时的HTTP状态码 数字 200 / 201
Response Headers 自定义响应头 JSON对象 {"Content-Type": "application/json"}

配置示例:

  • 场景: 创建一个接收POST请求的Webhook,用于接收新用户注册数据。
  • 配置:
HTTP Method: POST
Path: user-registered
Response Mode: On Received
Response Code: 201
Response Headers: {"Content-Type": "application/json"}

Manual

节点用途:

  • 允许用户手动触发工作流的执行,通常用于测试、审批流程或需要人工介入的场景。

使用场景:

  • 人工启动: 用户点击按钮后开始执行流程,如手动数据导入、流程测试。
  • 审批流程: 等待用户确认后再继续执行后续操作,如订单审核、内容发布。
  • 交互式操作: 在流程中暂停,等待用户输入或选择后再继续。

节点参数:

参数名称 含义 格式/选项 示例
Button Text 手动触发按钮上显示的文字 字符串 Start Processing
Description 对本次手动触发的描述信息 字符串 请确认数据无误后点击按钮开始处理
Output Format 输出数据的格式 JSON / String JSON

配置示例:

  • 场景: 设置一个手动触发节点,用于启动数据备份流程。
  • 配置:
Button Text: 开始备份
Description: 点击后开始执行数据库备份操作
Output Format: JSON

Interval

节点用途:

  • 按照固定的时间间隔(如每5分钟、每1小时)循环触发工作流的执行。

使用场景:

  • 周期轮询: 定期检查新邮件、新订单、API数据更新等。
  • 定时任务: 执行不需要复杂时间规则只需固定间隔的任务,如每10分钟同步一次数据。
  • 心跳检测: 每隔一段时间执行一次状态检查或服务监控。

节点参数:

参数名称 含义 格式/选项 示例
Interval Value 时间间隔数值 正整数 30
Interval Unit 时间间隔单位 Seconds / Minutes / Hours Minutes
Start Time 首次开始执行的时间 日期时间(可选) 2023-10-01T08:00:00
End Time 结束执行的时间 日期时间(可选) 2023-10-31T18:00:00

配置示例:

  • 场景: 每30分钟触发一次工作流,检查系统状态。
  • 配置:
Interval Value: 30
Interval Unit: Minutes
Start Time: (可选)
End Time: (可选)

Polling

节点用途:

  • 通过定期轮询(检查)某个外部服务或API来获取新数据或状态变化,并触发工作流。

使用场景:

  • 数据同步: 定期检查数据库、API或服务是否有新记录或更新。
  • 事件检测: 轮询检测特定条件是否满足,如文件是否上传完成、任务是否结束。
  • 状态监控: 持续监控系统、服务或设备的状态变化。

节点参数:

参数名称 含义 格式/选项 示例
Resource 要轮询的资源类型 取决于所选应用(如Airtable为Table,Google Sheets为Spreadsheet Table
Operation 轮询操作类型 Get Many (获取多条) / Get (获取单条) Get Many
Polling Frequency 轮询频率 Every Minute / Every 5 Minutes / Every 30 Minutes / Every Hour Every 5 Minutes
Filters 过滤条件 取决于资源(如日期字段、状态字段) Created Time > {{ yesterday }}

配置示例:

  • 场景: 每5分钟轮询一次Airtable的某个表,获取新记录。
  • 配置:
Resource: Table
Operation: Get Many
Polling Frequency: Every 5 Minutes
Filters: ISNULL({Processed}) (仅获取未处理的记录)

Cron

节点用途:

  • 使用Cron表达式定义复杂的时间计划规则,在精确的时间点自动触发工作流执行。

使用场景:

  • 复杂调度: 需要在特定星期、日期、时间组合下执行的任务,如“每月最后一个工作日下午3点”。
  • 精细控制: 对执行时间有非常精确要求的场景,如金融市场数据获取。
  • 传统调度: 替代系统自带的Cron任务,实现更灵活的 workflow 集成。

节点参数:

参数名称 含义 格式/选项 示例
Cron Expression Cron表达式,定义执行时间规则 字符串(标准Cron格式) 0 9 * * 1-5 (周一至周五9点)
Timezone 时区设置 时区字符串 UTC / America/New_York
Run On Init 工作流初始化时是否立即运行一次 Yes / No No

配置示例:

  • 场景: 每周一至周五上午9点执行报告生成任务。
  • 配置:
Cron Expression: 0 9 * * 1-5
Timezone: Asia/Shanghai
Run On Init: No

Telegram Trigger

节点用途:

  • 监听Telegram机器人接收到的消息、命令或其他事件,并触发工作流执行。

使用场景:

  • 消息处理: 自动回复用户消息、关键词触发、消息转发。
  • 命令响应: 用户使用斜杠命令(如 /start, /help)时执行特定操作。
  • 群组管理: 监控群组消息、新成员加入、离开等事件。

节点参数:

参数名称 含义 格式/选项 示例
Event Type 要监听的Telegram事件类型 Message / Callback Query / Inline Query / Channel Post Message
Trigger Type 触发类型 Webhook (推荐) / Polling Webhook
Filters 过滤条件 Text / Command / Contains / Regex Command /start

配置示例:

  • 场景: 当用户向机器人发送 /start 命令时触发工作流。
  • 配置:
Event Type: Message
Trigger Type: Webhook
Filters: Command /start

WhatsApp Trigger (by Cloud API)

节点用途:

  • 通过Cloud API监听接收到的WhatsApp消息、媒体文件或状态报告,并触发工作流执行。

使用场景:

  • 客户服务: 自动回复客户消息、处理订单查询、发送通知。
  • 营销自动化: 用户发送特定关键词后触发发送优惠券或产品信息。
  • 状态跟踪: 监听消息的发送状态(已发送、已送达、已阅读)。

节点参数:

参数名称 含义 格式/选项 示例
Event Type 要监听的WhatsApp事件类型 Message / Media / Status Message
Phone Number ID 发起API调用的电话号码ID 字符串(数字ID) 1234567890
Business Account ID Meta Business Account ID 字符串(数字ID) 9876543210
Filters 过滤条件 Text / Contains / From (特定发件人) Contains order

配置示例:

  • 场景: 当收到包含“订单”一词的WhatsApp消息时触发工作流。
  • 配置:
Event Type: Message
Phone Number ID: {{$vars.PHONE_NUMBER_ID}}
Business Account ID: {{$vars.BUSINESS_ACCOUNT_ID}}
Filters: Contains order

Google Calendar Trigger

节点用途:

  • 监听Google Calendar中的事件变化,如新事件创建、事件更新、事件删除或事件开始,并触发工作流。

使用场景:

  • 会议提醒: 事件开始前自动发送提醒消息(邮件、Slack、短信)。
  • 日程同步: 当日历中出现新会议时,同步到其他系统(如CRM、项目管理工具)。
  • 资源预订: 监控特定日历的事件变化,管理会议室、设备等资源的预订状态。

节点参数:

参数名称 含义 格式/选项 示例
Calendar 要监听的Google日历 从已认证账户的日历列表中选择 primary (主日历)
Event 触发工作流的日历事件类型 Event Created / Event Updated / Event Started / Event Cancelled Event Created
Use Polling 是否使用轮询模式 Yes / No (通常Webhook更好) No

配置示例:

  • 场景: 当主日历中有新事件创建时触发工作流。
  • 配置:
Calendar: primary
Event: Event Created
Use Polling: No

Shopify Trigger

节点用途:

  • 监听Shopify商店中发生的事件,如新订单创建、产品更新、客户注册等,并触发工作流。

使用场景:

  • 订单处理: 新订单到来时自动通知团队、更新库存、触发发货流程。
  • 客户管理: 新客户注册时发送欢迎邮件、将其信息同步到CRM。
  • 库存预警: 产品库存低于阈值时自动发送告警通知。

节点参数:

参数名称 含义 格式/选项 示例
Resource 要监听的Shopify资源类型 Order / Product / Customer / Draft Order Order
Operation 针对资源的具体操作事件 Created / Updated / Deleted Created
Webhook Version Shopify API版本 下拉选择(如2023-10 2023-10

配置示例:

  • 场景: 当商店中有新订单创建时触发工作流。
  • 配置:
Resource: Order
Operation: Created
Webhook Version: 2023-10

Slack Trigger

节点用途:

  • 监听Slack工作区中的特定事件,如新消息、频道反应(Reaction)、用户加入等,并触发工作流。

使用场景:

  • 消息监控: 在特定频道或收到DM时触发自动化回复或记录。
  • 反应处理: 当用户对某条消息添加了特定反应(如✅)时执行操作。
  • 团队协作自动化: 新成员加入频道时自动发送欢迎消息和文档。

节点参数:

参数名称 含义 格式/选项 示例
Event 要监听的Slack事件类型 Message / Reaction Added / Channel Created / User Joined Channel Message
Channel 监听的频道(对于消息事件) 频道ID或名称(如#general #general
Trigger Pattern 触发模式(如关键词) 字符串(正则表达式可选) ^help (以help开头的消息)

配置示例:

  • 场景: 当在#support频道中收到以“help”开头的消息时触发工作流。
  • 配置:
Event: Message
Channel: #support
Trigger Pattern: ^help

Typeform Trigger

节点用途:

  • 监听Typeform表单的新提交事件,当有用户提交表单时自动获取提交数据并触发工作流。

使用场景:

  • 表单处理: 自动处理问卷调查、注册表单、反馈收集的提交结果。
  • 潜在客户生成: 新表单提交时,将潜在客户信息同步到CRM或邮件列表。
  • 数据入库: 将表单提交的回答自动保存到数据库或电子表格中。

节点参数:

参数名称 含义 格式/选项 示例
Form 要监听的Typeform表单 从已认证账户的表单列表中选择 Customer Feedback Form
Trigger On 触发时机 Form Submitted (表单提交) Form Submitted
Webhook Tag Webhook标识标签 字符串(用于区分多个Webhook) TeGo-AI -workflow

配置示例:

  • 场景: 当“客户反馈表”有新的提交时触发工作流。
  • 配置:
Form: Customer Feedback Form
Trigger On: Form Submitted
Webhook Tag:  TeGo-AI -workflow

Discord Trigger

节点用途:

  • 监听Discord服务器(Guild)中的消息、反应或其他事件,并触发工作流执行。

使用场景:

  • 社区管理: 自动审核新消息、响应特定命令、欢迎新成员。
  • 游戏集成: 监听游戏服务器状态变化或在Disc中发布游戏通知。
  • 内容转发: 将Discord中特定频道的消息转发到其他平台(如Slack、Telegram)。

节点参数:

参数名称 含义 格式/选项 示例
Guild Discord服务器(Guild) 从已认证账户的服务器列表中选择 My Community Server
Event 要监听的Discord事件类型 Message / Reaction Add / Member Join Message
Channel 监听的文本频道 从所选服务器的频道列表中选择 #general

配置示例:

  • 场景: 当在“我的社区服务器”的“#general”频道中有新消息时触发工作流。
  • 配置:
Guild: My Community Server
Event: Message
Channel: #general

Facebook Trigger

节点用途:

  • 监听Facebook Page(粉丝专页)发生的事件,如收到新消息、新帖子、帖子评论等,并触发工作流。

使用场景:

  • 社交媒体管理: 自动回复粉丝专页的私信、评论管理、新帖子通知。
  • 潜在客户追踪: 当用户在广告评论区表示兴趣时,自动捕获潜在客户信息。
  • 互动分析: 跟踪帖子的点赞、分享和评论数据。

节点参数:

参数名称 含义 格式/选项 示例
Page 要监听的Facebook粉丝专页 从已认证账户的专页列表中选择 My Business Page
Event 要监听的专页事件类型 Message / Feed (帖子) / Comments Message
App Secret Facebook应用密钥(用于验证) 字符串 {{$secrets.FACEBOOK_APP_SECRET}}

配置示例:

  • 场景: 当“我的商业专页”收到新的私信时触发工作流。
  • 配置:
Page: My Business Page
Event: Message
App Secret: {{$secrets.FACEBOOK_APP_SECRET}}

Twitter Trigger

节点用途:

  • 监听Twitter(X)账户的相关事件,如收到新推文、提及、点赞、新粉丝等,并触发工作流。

使用场景:

  • 品牌监控: 监听提及品牌或产品的推文,自动回复或记录。
  • 社交互动: 自动感谢新粉丝、响应特定的提及或关键词。
  • 内容聚合: 收集带有特定话题标签(Hashtag)的推文。

节点参数:

参数名称 含义 格式/选项 示例
Event 要监听的Twitter事件类型 Mention / Tweet / Like / Follow Mention
Search Term 搜索词/过滤器(对于Mention/Tweet) 字符串(关键词、@用户名、#标签) @mycompany
Use Polling 是否使用轮询模式(Webhook不可用时) Yes / No No

配置示例:

  • 场景: 当Twitter账户收到包含“@mycompany”的提及时触发工作流。
  • 配置:
Event: Mention
Search Term: @mycompany
Use Polling: No

GitHub Trigger

节点用途:

  • 监听GitHub仓库中发生的事件,如新的Push、Issue、Pull Request、Star等,并触发工作流。

使用场景:

  • 开发运维: 代码推送后自动触发测试、构建或部署流程。
  • 项目管理: 新建Issue时自动分配标签或通知团队,PR合并时更新状态。
  • 社区互动: 有人Star或Fork仓库时发送感谢消息或记录。

节点参数:

参数名称 含义 格式/选项 示例
Repository 要监听的GitHub仓库 所有者/仓库名 格式 TeGo-AI -io/ TeGo-AI
Events 要监听的GitHub事件类型 Push / Issues / Pull Request / Star / Fork Push
Additional Events 其他事件(取决于主事件选择) 多种选项(如opened, closed for Issues) opened (对于Issues事件)

配置示例:

  • 场景: 当监听的仓库有代码Push时触发工作流。
  • 配置:
Repository: my-username/my-repo
Events: Push
Additional Events: (Push事件无此选项)

TheHive Project Trigger

节点用途:

  • 监听TheHive安全事件响应平台中的事件,如新告警(Alert)、新案件(Case)创建或更新,并触发工作流。

使用场景:

  • 安全事件响应: 当TheHive从监控系统(如MISP、SIEM)接收到新告警时,自动创建案件或通知安全团队。
  • 案件工作流自动化: 案件状态更新(如从“Open”变为“In Progress”)时触发后续处理流程。
  • 协同处理: 将新案件或告警自动分配给相应的分析人员或团队。

节点参数:

参数名称 含义 格式/选项 示例
Resource 要监听的TheHive资源类型 Alert / Case Alert
Operation 针对资源的具体操作事件 Created / Updated Created
Use Polling 是否使用轮询模式 Yes / No (Webhook更高效) No

配置示例:

  • 场景: 当TheHive中有新告警(Alert)创建时触发工作流。
  • 配置:
Resource: Alert
Operation: Created
Use Polling: No

Mattermost Trigger

节点用途:

  • 监听Mattermost团队协作平台中的事件,如新消息、反应添加到消息、用户加入频道等,并触发工作流。

使用场景:

  • 内部自动化: 在特定频道中监听关键词或命令,触发内部工具操作(如部署、查询)。
  • 通知集成: 将其他系统的通知转发到Mattermost频道,或根据Mattermost消息触发其他通知。
  • 团队协作: 新用户加入团队或频道时自动分配角色或发送欢迎信息。

节点参数:

参数名称 含义 格式/选项 示例
Team Mattermost团队 从已认证账户的团队列表中选择 My Team
Event 要监听的Mattermost事件类型 Message / Reaction Added / User Added Message
Channel 监听的频道 从所选团队的频道列表中选择 off-topic

配置示例:

  • 场景: 当在“My Team”团队的“off-topic”频道中有新消息时触发工作流。
  • 配置:
Team: My Team
Event: Message
Channel: off-topic

Jira Software Trigger

节点用途:

  • 监听Jira Software中的事件,如问题(Issue)创建、更新、评论、转换状态等,并触发工作流。

使用场景:

  • 项目管理自动化: 新问题创建时自动分配经办人、设置优先级或通知相关人员。
  • 状态跟踪: 问题状态改变(如从“To Do”变为“In Progress”)时更新外部系统或发送通知。
  • 同步信息: 将Jira问题的评论同步到Slack频道或其他协作工具。

节点参数:

参数名称 含义 格式/选项 示例
Project 要监听的Jira项目 从已认证账户的项目列表中选择 MYPROJ
Event 要监听的Jira事件类型 Issue Created / Issue Updated / Issue Deleted Issue Created
Use Webhook 是否使用Webhook(推荐) Yes / No (Polling备用) Yes

配置示例:

  • 场景: 当在“MYPROJ”项目中有新问题(Issue)创建时触发工作流。
  • 配置:
Project: MYPROJ
Event: Issue Created
Use Webhook: Yes

Bitbucket Trigger

节点用途:

  • 监听Bitbucket仓库中发生的事件,如新的Push、Pull Request、Issue创建等,并触发工作流。

使用场景:

  • CI/CD集成: 代码推送或PR创建时自动触发构建、测试流水线。
  • 代码审查管理: PR有新评论或批准时通知相关人员,PR合并后自动关闭关联任务。
  • 仓库监控: 监控特定分支的推送活动或Issue的创建和更新。

节点参数:

参数名称 含义 格式/选项 示例
Repository 要监听的Bitbucket仓库 workspace / 仓库名 格式 my-team/my-repo
Events 要监听的Bitbucket事件类型 Push / Pull Request / Issue Push
Use Webhook 是否使用Webhook(推荐) Yes / No (Polling备用) Yes

配置示例:

  • 场景: 当监听的Bitbucket仓库有代码Push时触发工作流。
  • 配置:
Repository: my-team/my-repo
Events: Push
Use Webhook: Yes

Microsoft Teams Trigger

节点用途:

  • 监听Microsoft Teams团队或频道中的事件,如新消息、会议开始、用户加入团队等,并触发工作流。

使用场景:

  • 团队协作自动化: 在频道中监听特定命令或关键词,触发信息查询或流程启动。
  • 会议管理: 新会议开始时自动记录出席情况或发送提醒。
  • 新成员引导: 新用户加入团队或频道时自动发送欢迎消息和资源链接。

节点参数:

参数名称 含义 格式/选项 示例
Team Microsoft Teams团队 从已认证账户的团队列表中选择 Marketing Team
Event 要监听的Teams事件类型 Message / Channel Created / Meeting Started Message
Channel 监听的频道(对于消息事件) 从所选团队的频道列表中选择 General

配置示例:

  • 场景: 当在“Marketing Team”团队的“General”频道中有新消息时触发工作流。
  • 配置:
Team: Marketing Team
Event: Message
Channel: General

Pipedrive Trigger

节点用途:

  • 监听Pipedrive CRM中的事件,如新交易(Deal)创建、更新、阶段变化,或新人员(Person)、组织(Organization)创建等,并触发工作流。

使用场景:

  • 销售自动化: 新交易创建时自动分配负责人、设置提醒或创建后续任务。
  • 客户生命周期管理: 交易阶段变化(如从“Qualification”变为“Proposal”)时触发特定动作。
  • 数据同步: 将新的潜在客户(Person)或组织(Organization)同步到其他系统(如邮件营销工具)。

节点参数:

参数名称 含义 格式/选项 示例
Resource 要监听的Pipedrive资源类型 Deal / Person / Organization / Activity Deal
Operation 针对资源的具体操作事件 Created / Updated (可能包含特定字段变化) Created
Use Webhook 是否使用Webhook(推荐) Yes / No (Polling备用) Yes

配置示例:

  • 场景: 当Pipedrive中有新交易(Deal)创建时触发工作流。
  • 配置:
Resource: Deal
Operation: Created
Use Webhook: Yes

Airtable Trigger

节点用途:

  • 监听Airtable基座(Base)中特定表(Table)的记录变化,如新增、更新或删除记录,并触发工作流。

使用场景:

  • 无代码数据库监听: Airtable表作为轻量级数据库,新记录添加时触发后续处理(如发送通知、处理数据)。
  • 数据收集管道: 表单提交、用户反馈等数据流入Airtable后,自动进行加工或同步到其他系统。
  • 状态跟踪: 监控Airtable表中某条记录特定字段的更新(如状态从“Pending”变为“Approved”)。

节点参数:

参数名称 含义 格式/选项 示例
Base 要监听的Airtable基座(Base) 从已认证账户的基座列表中选择 Project Tracker
Table 基座中要监听的具体表(Table) 从所选基座的表列表中选择 Tasks
Event 要监听的表事件类型 Record Created / Record Updated / Record Deleted Record Created
Use Polling 是否使用轮询模式(Airtable需付费计划才支持Webhook) Yes / No Yes (免费计划常用)

配置示例:

  • 场景: 当“Project Tracker”基座的“Tasks”表中有新记录创建时触发工作流。
  • 配置:
Base: Project Tracker
Table: Tasks
Event: Record Created
Use Polling: Yes

Asana Trigger

节点用途:

  • 监听Asana工作区中的事件,如新任务(Task)创建、任务完成、任务分配、新评论等,并触发工作流。

使用场景:

  • 项目管理自动化: 新任务创建时自动设置截止日期、分配标签或通知负责人。
  • 进度跟踪: 任务标记为完成时,更新相关文档或触发庆祝消息。
  • 跨工具同步: 将Asana中的任务评论或状态变化同步到Slack频道或其他协作工具。

节点参数:

参数名称 含义 格式/选项 示例
Workspace Asana工作区 从已认证账户的工作区列表中选择 My Company
Project 工作区中的项目(可选,可监听所有项目) 从工作区的项目列表中选择 Website Launch
Event 要监听的Asana事件类型 Task Created / Task Completed / Task Assignment Added Task Created
Use Webhook 是否使用Webhook(推荐) Yes / No (Polling备用) Yes

配置示例:

  • 场景: 当在“My Company”工作区的“Website Launch”项目中有新任务创建时触发工作流。
  • 配置:
Workspace: My Company
Project: Website Launch
Event: Task Created
Use Webhook: Yes

Trello Trigger

节点用途:

  • 监听Trello看板(Board)中的事件,如新卡片(Card)创建、卡片移动列表、卡片归档、添加成员等,并触发工作流。

使用场景:

  • 看板自动化: 新卡片添加到“待办”列表时自动分配成员、设置截止日期。
  • 状态流跟踪: 卡片从一个列表移动到另一个列表(如从“Doing”到“Done”)时触发通知或更新外部系统。
  • 协作通知: 当有成员被添加到卡片时,自动发送欢迎消息或提供上下文信息。

节点参数:

参数名称 含义 格式/选项 示例
Board 要监听的Trello看板(Board) 从已认证账户的看板列表中选择 Product Roadmap
Event 要监听的Trello事件类型 Card Created / Card Moved / Card Updated Card Created
List 监听的特定列表(List)(可选) 从所选看板的列表列表中选择 To Do
Use Webhook 是否使用Webhook(推荐) Yes / No (Polling备用) Yes

配置示例:

  • 场景: 当在“Product Roadmap”看板的“To Do”列表中有新卡片创建时触发工作流。
  • 配置:
Board: Product Roadmap
Event: Card Created
List: To Do
Use Webhook: Yes

Email Trigger (IMAP)

节点用途:

  • 通过IMAP协议监听邮箱账户,当收到新邮件或符合特定条件的邮件时触发工作流执行。

使用场景:

  • 邮件自动化处理: 自动回复特定发件人、根据邮件内容分类或转发重要邮件。
  • 通知提醒: 收到来自特定系统或服务的报警邮件时,转发到即时通讯工具。
  • 潜在客户管理: 捕获咨询邮件并自动创建CRM记录或任务。

节点参数:

参数名称 含义 格式/选项 示例
Mailbox 要监听的邮箱文件夹 字符串(如INBOX) INBOX
Action 触发后对邮件的操作 Mark as Read / Move to Folder / Nothing Mark as Read
Filters 邮件过滤条件 From / Subject / Has Attachment From: alerts@system.com
Polling Interval 检查新邮件的间隔时间 数字+单位(如5 minutes) 5 minutes

配置示例:

  • 场景: 当收件箱收到来自alerts@system.com的新邮件时触发工作流。
  • 配置:
Mailbox: INBOX
Action: Mark as Read
Filters: From: alerts@system.com
Polling Interval: 5 minutes

RSS Feed Trigger

节点用途:

  • 定期检查RSS源是否有新内容发布,当发现新项目时触发工作流。

使用场景:

  • 内容聚合: 监控新闻网站、博客更新,自动转发到社交媒体或内部平台。
  • 竞争情报: 跟踪竞争对手网站的产品发布或新闻动态。
  • 价格监控: 监控电商网站的RSS源获取价格变动信息。

节点参数:

参数名称 含义 格式/选项 示例
URL RSS源的URL地址 字符串(URL格式) https://example.com/feed
Polling Interval 检查更新的时间间隔 数字+单位(如1 hour) 1 hour
Use Polling 是否使用轮询模式 Yes / No Yes

配置示例:

  • 场景: 每小时检查一次示例网站的RSS更新。
  • 配置:
URL: https://example.com/feed
Polling Interval: 1 hour
Use Polling: Yes

S3 Trigger

节点用途:

  • 监控Amazon S3存储桶中的文件变化,当有新文件上传、删除或修改时触发工作流。

使用场景:

  • 文件处理流水线: 新文件上传时自动触发处理、转换或分析流程。
  • 备份监控: 监控备份文件的上传情况并发送通知。
  • 数据同步: 文件变化时同步到其他存储服务或数据库。

节点参数:

参数名称 含义 格式/选项 示例
Bucket 要监控的S3存储桶名称 字符串 my-data-bucket
Event 要监听的S3事件类型 Object Created / Object Deleted / Object Updated Object Created
Prefix 路径前缀过滤 字符串(可选) uploads/images/
Use Polling 是否使用轮询模式 Yes / No No(推荐使用S3事件通知)

配置示例:

  • 场景: 当有的新文件上传到指定存储桶时触发工作流。
  • 配置:
Bucket: my-data-bucket
Event: Object Created
Prefix: uploads/images/
Use Polling: No

Google Drive Trigger

节点用途:

  • 监控Google Drive中的文件变化,当有新文件创建、修改或删除时触发工作流。

使用场景:

  • 文档处理: 新文档上传时自动转换格式或提取内容。
  • 协作工作流: 团队文件夹中的文件更新时通知相关人员。
  • 备份同步: 监控特定文件夹的变化并同步到其他存储服务。

节点参数:

参数名称 含义 格式/选项 示例
Drive 要监控的Google Drive 从已认证账户的驱动器列表中选择 My Drive
Watch For 监控的文件变化类型 File Created / File Updated / File Deleted File Created
Folder 特定文件夹路径(可选) 字符串 Shared Folder/Projects
Use Polling 是否使用轮询模式 Yes / No No(推荐使用Webhook)

配置示例:

  • 场景: 当"我的云端硬盘"中有新文件创建时触发工作流。
  • 配置:
Drive: My Drive
Watch For: File Created
Folder: (可选)
Use Polling: No

Dropbox Trigger

节点用途:

  • 监控Dropbox账户中的文件变化,当有新文件添加、修改或删除时触发工作流。

使用场景:

  • 文件自动化: 新文件添加时自动处理或分发。
  • 团队协作: 共享文件夹中的文件变化时通知团队成员。
  • 数据备份: 监控重要文件的变化并创建备份。

节点参数:

参数名称 含义 格式/选项 示例
Path 要监控的Dropbox路径 字符串 /Shared/Files
Event 要监听的事件类型 File Added / File Updated / File Deleted File Added
Use Polling 是否使用轮询模式 Yes / No Yes(免费账户常用)

配置示例:

  • 场景: 当指定路径有新文件添加时触发工作流。
  • 配置:
Path: /Shared/Files
Event: File Added
Use Polling: Yes

OneDrive Trigger

节点用途:

  • 监控Microsoft OneDrive中的文件变化,当有新文件创建、更新或删除时触发工作流。

使用场景:

  • 文档管理: 新文档上传时自动进行分类或处理。
  • 企业协作: 监控团队OneDrive文件夹的变化并触发相应工作流。
  • 文件同步: 文件变化时同步到其他平台或服务。

节点参数:

参数名称 含义 格式/选项 示例
Path 要监控的OneDrive路径 字符串 /Documents/Work
Event 要监听的事件类型 File Created / File Updated / File Deleted File Created
Use Webhook 是否使用Webhook Yes / No Yes

配置示例:

  • 场景: 当指定路径有新文件创建时触发工作流。
  • 配置:
Path: /Documents/Work
Event: File Created
Use Webhook: Yes

FTP Trigger

节点用途:

  • 监控FTP服务器指定目录中的文件变化,当有新文件上传时触发工作流。

使用场景:

  • 传统系统集成: 从传统系统通过FTP传输的文件中提取和处理数据。
  • 批量处理: 监控FTP目录中的新文件并触发批量处理流程。
  • 数据采集: 从合作伙伴或第三方通过FTP发送的文件中采集数据。

节点参数:

参数名称 含义 格式/选项 示例
Protocol 协议类型 FTP / FTPS FTP
Host FTP服务器地址 字符串 ftp.example.com
Path 监控的目录路径 字符串 /incoming/files
Polling Interval 检查间隔时间 数字+单位 15 minutes

配置示例:

  • 场景: 每15分钟检查一次FTP指定目录的新文件。
  • 配置:
Protocol: FTP
Host: ftp.example.com
Path: /incoming/files
Polling Interval: 15 minutes

SFTP Trigger

节点用途:

  • 通过SFTP协议监控远程服务器指定目录中的文件变化,当有新文件时触发工作流。

使用场景:

  • 安全文件传输: 监控通过SFTP传输的敏感文件并触发安全处理流程。
  • 自动化数据摄入: 从SFTP服务器获取数据文件并进行自动化处理。
  • 系统集成: 与使用SFTP的传统企业系统集成。

节点参数:

参数名称 含义 格式/选项 示例
Host SFTP服务器地址 字符串 sftp.example.com
Path 监控的目录路径 字符串 /upload/data
File Pattern 文件模式匹配 字符串(支持通配符) *.csv
Polling Interval 检查间隔时间 数字+单位 30 minutes

配置示例:

  • 场景: 监控SFTP服务器上CSV文件的上传。
  • 配置:
Host: sftp.example.com
Path: /upload/data
File Pattern: *.csv
Polling Interval: 30 minutes

MySQL Trigger

节点用途:

  • 监控MySQL数据库表中的数据变化,当有新记录插入、更新或删除时触发工作流。

使用场景:

  • 实时数据同步: 数据库变化时同步到其他系统或服务。
  • 业务事件触发: 监控业务数据变化并触发相应业务流程。
  • 审计日志: 跟踪重要数据表的变更并生成审计记录。

节点参数:

参数名称 含义 格式/选项 示例
Database 数据库名称 字符串 production_db
Table 要监控的数据表 字符串 orders
Operation 监控的操作类型 Insert / Update / Delete Insert
Use Polling 是否使用轮询模式 Yes / No Yes

配置示例:

  • 场景: 监控订单表的新记录插入。
  • 配置:
Database: production_db
Table: orders
Operation: Insert
Use Polling: Yes

PostgreSQL Trigger

节点用途:

  • 监控PostgreSQL数据库表中的数据变化,当有数据变更时触发工作流。

使用场景:

  • 数据驱动自动化: 数据库变化时自动触发相关业务逻辑。
  • 实时通知: 重要数据变更时立即通知相关人员。
  • 数据管道: 构建基于数据库变更的数据处理管道。

节点参数:

参数名称 含义 格式/选项 示例
Database 数据库名称 字符串 analytics_db
Table 要监控的数据表 字符串 user_activity
Operation 监控的操作类型 Insert / Update / Delete Update
Use Listen 是否使用LISTEN/NOTIFY Yes / No Yes(推荐)

配置示例:

  • 场景: 监控用户活动表的更新操作。
  • 配置:
Database: analytics_db
Table: user_activity
Operation: Update
Use Listen: Yes

MongoDB Trigger

节点用途:

  • 监控MongoDB集合中的文档变化,当有新文档插入、更新或删除时触发工作流。

使用场景:

  • NoSQL数据流: 监控文档数据库的变化并触发处理流程。
  • 实时分析: 新数据插入时立即进行实时分析处理。
  • 数据同步: 将MongoDB数据变化同步到其他数据存储。

节点参数:

参数名称 含义 格式/选项 示例
Database 数据库名称 字符串 user_profiles
Collection 要监控的集合 字符串 profiles
Operation 监控的操作类型 Insert / Update / Delete / Replace Insert
Use Change Streams 是否使用变更流 Yes / No Yes(推荐)

配置示例:

  • 场景: 监控用户配置集合的新文档插入。
  • 配置:
Database: user_profiles
Collection: profiles
Operation: Insert
Use Change Streams: Yes

Redis Trigger

节点用途:

  • 监控Redis数据库中的键变化,当特定键的值发生变化或过期时触发工作流。

使用场景:

  • 缓存失效处理: 缓存键过期时重新生成数据或触发更新。
  • 实时消息队列: 监控Redis列表或发布/订阅频道的消息。
  • 分布式锁管理: 监控分布式锁的状态变化。

节点参数:

参数名称 含义 格式/选项 示例
Key 要监控的Redis键 字符串 user:session:*
Event 监控的事件类型 Key Expired / Key Deleted / Key Set Key Expired
Database Redis数据库编号 数字 0
Use Pattern 是否使用模式匹配 Yes / No Yes

配置示例:

  • 场景: 监控用户会话键的过期事件。
  • 配置:
Key: user:session:*
Event: Key Expired
Database: 0
Use Pattern: Yes

RabbitMQ Trigger

节点用途:

  • 监听RabbitMQ消息队列中的消息,当有新消息到达时触发工作流执行。

使用场景:

  • 消息处理: 从消息队列中消费消息并进行处理。
  • 系统集成: 作为不同系统间的消息桥梁。
  • 事件驱动架构: 在微服务架构中处理异步事件。

节点参数:

参数名称 含义 格式/选项 示例
Queue 要监听的队列名称 字符串 order_queue
Acknowledge 是否自动确认消息 Yes / No Yes
Prefetch Count 预取消息数量 数字 10
Durable 队列是否持久化 Yes / No Yes

配置示例:

  • 场景: 监听订单处理队列的消息。
  • 配置:
Queue: order_queue
Acknowledge: Yes
Prefetch Count: 10
Durable: Yes

Kafka Trigger

节点用途:

  • 监听Apache Kafka主题中的消息,当有新消息时触发工作流执行。

使用场景:

  • 流数据处理: 处理实时数据流并进行转换或分析。
  • 事件溯源: 处理事件溯源架构中的领域事件。
  • 大数据管道: 在大数据架构中处理数据流。

节点参数:

参数名称 含义 格式/选项 示例
Topic 要监听的Kafka主题 字符串 user_events
Group ID 消费者组ID 字符串 TeGo-AI -consumer
From Beginning 是否从最早消息开始 Yes / No No
Auto Commit 是否自动提交偏移量 Yes / No Yes

配置示例:

  • 场景: 监听用户事件主题的消息。
  • 配置:
Topic: user_events
Group ID:  TeGo-AI -consumer
From Beginning: No
Auto Commit: Yes

MQTT Trigger

节点用途:

  • 订阅MQTT主题并监听消息,当收到匹配主题的消息时触发工作流。

使用场景:

  • 物联网设备监控: 接收物联网设备发送的传感器数据。
  • 实时通知: 处理实时消息通知系统。
  • 设备控制: 监听设备状态变化并触发控制逻辑。

节点参数:

参数名称 含义 格式/选项 示例
Topic 要订阅的MQTT主题 字符串 sensors/temperature/#
QoS 服务质量等级 0 / 1 / 2 1
Retain 是否处理保留消息 Yes / No No
Clean Session 是否清理会话 Yes / No Yes

配置示例:

  • 场景: 订阅温度传感器主题的所有消息。
  • 配置:
Topic: sensors/temperature/#
QoS: 1
Retain: No
Clean Session: Yes

AWS SNS Trigger

节点用途:

  • 监听Amazon SNS(简单通知服务)主题的消息,当收到消息时触发工作流。

使用场景:

  • 云服务集成: 处理来自AWS服务的通知消息。
  • 分布式通知: 在分布式系统中处理广播消息。
  • 事件处理: 处理通过SNS发布的应用事件。

节点参数:

参数名称 含义 格式/选项 示例
Topic ARN SNS主题的ARN 字符串 arn:aws:sns:us-east-1:123456789012:my-topic
Protocol 订阅协议 HTTP / HTTPS HTTPS
Raw Message 是否接收原始消息 Yes / No No
Auto Confirm 是否自动确认订阅 Yes / No Yes

配置示例:

  • 场景: 监听指定SNS主题的消息。
  • 配置:
Topic ARN: arn:aws:sns:us-east-1:123456789012:my-topic
Protocol: HTTPS
Raw Message: No
Auto Confirm: Yes

AWS SQS Trigger

节点用途:

  • 监听Amazon SQS(简单队列服务)队列中的消息,当有新消息时触发工作流。

使用场景:

  • 消息队列处理: 处理来自SQS队列的异步消息。
  • 微服务通信: 在微服务架构中处理服务间通信。
  • 任务分发: 处理分布式任务分发系统中的消息。

节点参数:

参数名称 含义 格式/选项 示例
Queue URL SQS队列的URL 字符串 https://sqs.us-east-1.amazonaws.com/123456789012/my-queue
Delete Message 处理成功后是否删除消息 Yes / No Yes
Max Messages 每次获取的最大消息数 数字(1-10) 10
Wait Time 长轮询等待时间 数字(0-20秒) 20

配置示例:

  • 场景: 监听SQS队列并处理消息。
  • 配置:
Queue URL: https://sqs.us-east-1.amazonaws.com/123456789012/my-queue
Delete Message: Yes
Max Messages: 10
Wait Time: 20

Google Cloud Pub/Sub Trigger

节点用途:

  • 订阅Google Cloud Pub/Sub主题并监听消息,当收到消息时触发工作流。

使用场景:

  • 云事件处理: 处理Google Cloud平台的事件通知。
  • 实时数据流: 处理实时数据流和分析流水线。
  • 跨服务集成: 在GCP服务间进行事件驱动的集成。

节点参数:

参数名称 含义 格式/选项 示例
Topic Pub/Sub主题名称 字符串 projects/my-project/topics/my-topic
Subscription 订阅名称 字符串 TeGo-AI -subscription
Ack Deadline 确认截止时间 数字(秒) 300
Create Subscription 是否自动创建订阅 Yes / No Yes

配置示例:

  • 场景: 订阅Google Cloud Pub/Sub主题的消息。
  • 配置:
Topic: projects/my-project/topics/my-topic
Subscription:  TeGo-AI -subscription
Ack Deadline: 300
Create Subscription: Yes

原图
上一张
下一张
放大
缩小
🖱️ 拖拽移动
ESC 关闭