ETL管道

此工作流适合以下人群：
- 社交媒体分析师：希望自动获取与特定主题相关的推文并进行情感分析。
- 数据科学家：需要将社交媒体数据存储到数据库中以进行进一步分析和建模。
- 市场营销人员：希望实时监控与品牌相关的社交媒体动态，并及时做出反应。
- 开发者：希望集成社交媒体数据到现有应用中，进行数据挖掘和分析。

此工作流解决了以下问题：
- 信息过载：自动从 Twitter 中提取与特定主题（如 #OnThisDay）相关的推文，避免手动搜索。
- 情感分析：利用 Google Cloud Natural Language API 对推文进行情感评分，帮助用户快速了解公众情绪。
- 数据存储：将推文存储到 PostgreSQL 和 MongoDB 数据库中，便于后续分析和查询。
- 实时通知：通过 Slack 通知团队关于重要推文的情感评分，确保团队及时获取关键信息。

工作流过程的详细说明：
1. 定时触发（Cron）：每日上午 6:00 自动触发工作流。
2. 获取推文（Twitter）：从 Twitter 中搜索与 #OnThisDay 相关的最新 3 条推文。
3. 存储推文（MongoDB）：将获取的推文内容插入到 MongoDB 的 tweets 集合中。
4. 情感分析（Google Cloud Natural Language）：对存储在 MongoDB 中的推文文本进行情感分析，获取情感评分和强度。
5. 设置数据（Set）：将情感分析结果（评分和强度）以及推文文本存储为变量，以便后续使用。
6. 存储到数据库（Postgres）：将推文文本、情感评分和强度存储到 PostgreSQL 的 tweets 表中。
7. 条件判断（IF）：根据情感评分判断是否需要发送通知。
8. 发送通知（Slack）：如果情感评分超过设定值，则通过 Slack 通知相关团队，内容包括推文文本和情感评分。
9. 无操作（NoOp）：如果情感评分未达到发送条件，则执行无操作，结束流程。

用户可以通过以下方式自定义和调整此工作流：
- 修改推文搜索关键词：在 Twitter 节点中更改 searchText 参数，以获取与其他主题相关的推文。
- 调整定时触发时间：在 Cron 节点中修改 hour 参数，以更改工作流的触发时间。
- 更改数据库表和集合：在 PostgreSQL 和 MongoDB 节点中修改表名和集合名，以适应用户的数据库结构。
- 调整情感评分条件：在 IF 节点中修改条件，以更改触发 Slack 通知的情感评分阈值。
- 自定义 Slack 消息内容：在 Slack 节点中调整 text 参数，以更改发送的消息格式和内容。