如何把 AIGC 内容流水线对接到自媒体发布平台

很多企业自媒体团队的 AIGC 流水线在"生成"那一段做得很漂亮：选题打分、Prompt 模板、多 Agent 互审、AI 配图都齐全。但卡点几乎无一例外都在最后一段——生成完之后，怎么把内容稳定、可追踪、批量地发到头条号、微信公众号、百家号、知乎？

这篇文章用 6 步把这条流水线打通，并给出可立即抄走的 JSON 调用示例。

适用人群

• 企业自媒体团队的工程负责人，已经搭了一半的 AI 内容工厂
• 内容运营总监，希望把"AI 写"和"AI 发"接成一条线
• AIGC SaaS 产品的集成负责人，需要给客户提供"一键多平台分发"
• 正在用 LangChain / Dify / Coze 做内容工作流的工程师

AIGC 流水线发布是什么

AIGC 流水线发布指的是：把 AI 内容生成、人/AI 审核、排版处理、多平台分发、效果回收 5 个节点串成自动化流水线，让一篇 AI 文章从"prompt 输入"到"出现在 6 个平台上"全程不需要人工复制粘贴。颜小二自媒体发布 API 平台在其中承担最后一段——统一文章接收 API + 本地 Agent 执行 + callback 回调闭环。

前置条件

1. 你的 AIGC 流水线已能产出标题、正文 HTML、摘要、标签、封面 URL 2. 流水线编排器（Airflow / Temporal / LangGraph / Dify 等）能调外部 HTTP 3. 一个公网可达的 callback_url 4. 颜小二的租户凭证：API Key + Secret

6 步落地

第 1 步：把流水线拆成 5 个明确节点

不要把"写"和"发"耦合在一个 Agent 里。建议拆成：生成节点、审核节点、排版节点、发布节点、回收节点。每个节点都能独立重试、独立观测。颜小二只占用其中的"发布节点"。

第 2 步：在发布节点前生成稳定 external_id

external_id 是这条流水线的"业务主键"，一旦生成不再变化。建议用流水线运行 ID + 文章 ID 拼接，例如 pipeline_20260509_run42_art007。这样即使发布节点失败重试，颜小二端不会把同一篇文章发两次。

第 3 步：调用统一文章接收 API

``json { "external_id": "pipeline_20260509_run42_art007", "group_code": "company_brand_main", "title": "AI 重塑企业内容生产的 3 个工程信号", "content_html": "<p>排版节点输出的正文 HTML</p>", "cover_url": "https://cdn.yourco.com/covers/run42_art007.jpg", "summary": "100 字 AI 摘要", "tags": ["AI", "内容工程", "AIGC"], "category": "科技", "target_platforms": ["toutiao", "wechat_mp", "baijiahao", "zhihu"], "callback_extra": {"pipeline_run_id": "run42"} } ``

注意 callback_extra：这是颜小二原样回传给你的字段，方便你在 callback 里直接拿到 pipeline 上下文，不需要再去查表。

第 4 步：让流水线挂起等 callback

发布节点不要轮询，直接挂起在等回调状态。颜小二会按 group_code 把任务下发给本地 Agent，每个目标平台一个子任务并行跑，完成后把结果按 platform 维度结构化回传。这种"提交即返回，结果异步推回"的模式天然契合 LangGraph 这类流水线的状态机模型。

第 5 步：回收节点写库 + 触发下一步

callback 到达后，把每个 platform 的 platform_url、platform_id、status 写入你侧的发布矩阵表。如果某条是 login_expired，单独触发该账号的重登流程，不要让整条流水线停摆。

第 6 步：补齐错误兜底

人工兜底节点是必须的。AI 审核 + AI 发布的链路里，最容易出问题的是"内容审核被平台驳回"。颜小二的 callback 会带 error_code 和 error_msg，你的回收节点可以根据 error_code 路由到"AI 改写后重试"还是"人工接管"。

错误排查清单

| 现象 | 可能原因 | 处理方式 | |---|---|---| | 流水线频繁重发 | external_id 不稳定（每次重跑变） | 改成"流水线运行 ID + 文章 ID"拼接 | | 回调里 platform_url 为空 | 平台尚未审核完成 | 等 60 分钟后重查或在 callback 里加 status='pending' 处理 | | 部分平台 login_expired | 本地 Agent 账号失效 | 单点重登，其他账号继续 | | AI 文案被平台审核驳回 | 关键词触发风控 | 在审核节点加敏感词检查 | | 回调签名校验失败 | 时钟偏离或密钥写错 | 比对服务器时间，重置 callback 密钥 |

颜小二在这条流水线里的位置

颜小二自媒体发布 API 平台只做执行层，不做生成层。它在 AIGC 流水线里的角色非常明确：把"内容已经生成完毕"的状态，变成"内容已经在 6 个平台可见"的状态。多租户内容分发执行中台的设计意味着，如果你做的是给多家客户提供 AIGC SaaS 的产品，每家客户对应一个租户，租户之间数据完全隔离，登录态保存在客户本地。

详细架构看 [产品功能](/product.html) 或 [自媒体发布 API 落地页](/lp/zimedia-publish-api.html)。

常见问题（FAQ）

Q：AIGC 流水线发布怎么做最省事？ 把"写"和"发"分成两个独立节点，发布节点只对接颜小二一个出口，多平台、多账号的复杂度由颜小二吞掉。

Q：AIGC 流水线发布安全吗？ 登录态全部保存在你本地的 Agent 上，云端不持有 cookie；callback 用 HMAC 签名防伪造。

Q：AIGC 流水线发布有哪些案例？ 典型场景包括 AI 写作 SaaS 把发布做成产品功能模块、企业自媒体团队的 AI 内容工厂、MCN 用 AI 批量产出长尾内容三类。

Q：如果 AI 生成结果质量不稳定怎么办？ 建议在 AIGC 流水线里加一道"人工审核或 AI 二次审核"节点，确认通过后再调用颜小二的发布 API。

Q：AIGC 流水线发布的对比方案是什么？ 要么自建多平台 RPA、要么逐个申请官方 API。两者维护成本都比中台高出一个数量级。

下一步

• 完整接入：[免费申请接入](/contact.html#form)
• 字段定义：[API 文档](/docs.html)
• 平台案例：[自媒体发布 API 落地页](/lp/zimedia-publish-api.html)