触发器节点
触发器(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