扮演 High-Frequency RSS Ingestio…
扮演 High-Frequency RSS Ingestion Architect 的专业角色能力（来自开源提示词库）
High-Frequency RSS Ingestion Architect能帮你做什么
不说虚话——S7501 交付的是能直接拿去用的成品，不是“AI 能做”的空话。
用大白话交代任务，它会先确认关键细节再动手，不瞎猜。
输出带结构与说明，拿来就能用，不用再自己整理格式。
与 AIXX 其他技能叠加使用，组成你自己的工作流。
把常用要求沉淀成一句话模板，下次直接复用。
真实任务实跑产出
下面是真实任务由 S7501 实际生成的内容节选——不是宣传文案，是它真的干出来的活。
High-Frequency RSS Ingestion Architect · 实跑样例
任务：帮我设计一个RSS采集方案：要订阅TechCrunch等30个科技博客源，每10分钟抓一次，单日预计处理5万条，怎么用Python加消息队列做到不丢不重？
# RSS采集方案：30源/10分钟/日均5万条不丢不重架构
一、总体架构
```
调度器(APScheduler) → 抓取器(多进程) → Redis Stream → 消费者(去重+解析)
→ PostgreSQL(主存) → Elasticsearch(检索)
```
二、核心设计
1. 去重机制（三重保障）
```python
import redis, hashlib
r = redis.Redis()
def get_key(item):
# 优先guid，其次链接归一化，最后正文指纹
norm_url = item.link.split('?')[0].rstrip('/')
return hashlib.sha256(
(item.get('guid', norm_url) + item.title[:50]).encode()
).hexdigest()
def is_dup(key):
# SETNX + 7天TTL，幂等去重
return not r.set(f"dedup:{key}", 1, nx=True, ex=7*86400)
```
2. 不丢数据：Redis Stream + 消费组确认
```python
# 生产端
r.xadd("rss:raw", {"feed": feed_name, "item": json.dumps(item)})
# 消费端（至少一次语义）
while True:
entries = r.xreadgroup("workers", "consumer-1",
{"rss:raw": ">"}, count=100, block=5000)
for msg_id, data in entries:
try:
process_and_save(data) # 写PG成功后
r.xack("rss:raw", "workers", msg_id) # 才ACK
except Exception:
pass # 不ACK，进入PEL待重试
# 兜底：XAUTOCLAIM扫描超时未ACK消息（幂等重放）
```
3. 写入幂等（防重复落库）
```sql
INSERT INTO articles (dedup_key, title, url, feed, published, content)
VALUES (%s, %s, %s, %s, %s, %s)
ON CONFLICT (dedup_key) DO NOTHING; -- dedup_key建唯一索引
```
4. 调度与抓取
```python
from apscheduler.schedulers.blocking import BlockingScheduler
sched = BlockingScheduler()
@sched.scheduled_job('interval', minutes=10, jitter=60)
def poll_all():
# 30源并发抓取，抓取前记录Etag/Last-Modified，304则跳过
with ProcessPoolExecutor(8) as pool:
pool.map(fetch_feed, FEEDS)
```
抓取器维护每源游标（etag），异常时保留原游标下次重试，天然不丢。
三、容量核算
- 10分钟一
三种做法,一比就知道
| 再招一个人 | 自己摸索 | 萬安云 S7501 | |
|---|---|---|---|
| 价格 | 月薪数千起 | 反复试错数小时 | $1.99 / 次 |
| 交付周期 | 招聘+培训数周 | 质量不稳定 | 分钟级 |
| 独特性 | 流动风险 | 无人复核 | 按你的任务从零生成 |
| 改稿迭代 | 加钱，走流程 | 反复试错 | 说话就能迭代 |
两步,让它开工
不用碰终端——你只管对 agent 说话,跑命令的活它来。
对你的 agent 说:
对你的 agent 说:
以上 Agent 均可接入萬安云 · OpenAI 兼容接口 · 装好 AIXX 即可调用全部技能
你可能想问
High-Frequency RSS Ingestion Architect怎么安装使用？
三步：终端执行 npx aixxai 安装 AIXX；对您的 AI 说「安装编号 S7501」；交代任务背景与要求，High-Frequency RSS Ingestion Architect即刻开工。
High-Frequency RSS Ingestion Architect多少钱？怎么付费？
$1.99 一次买断（参考价，实际以平台标价为准）——永久使用，无订阅、无月费；该技能由萬安永久维护迭代，更新对已购用户免费。
产出内容能商用吗？
可以。产出为普通数字文件，归购买者使用，可用于商业场景。
具体能帮我做什么？
把你手头这件重复、费时、有固定套路的活交给它——先描述任务和背景，它会确认要点后直接产出成品，不满意可以继续改。
输出质量不稳定怎么办？
在指令里补充背景、受众与格式要求（例如“面向中小企业主、300 字以内、分三点”）；要求越具体，产出越稳。
一价买断,没有套路
永久使用 · 无订阅无月费 · 永久维护迭代