Marketing Orchestrator 技能

用途

通过按顺序运行以下采集器代理（collector agents），编排营销审计流水线（marketing audit pipeline）：

• Instagram Collector
• Meta Ads Collector
• SEO / Keyword Collector
• Competitor Finder
• Website Audit Collector

聚合各采集器的独立结果，并调用 Report Generator 技能生成最终的综合性营销审计报告。

输入 Schema

interface MarketingInput {
  instagramHandle?: string;
  websiteDomain?: string;
}

输出 Schema

interface MarketingAuditReport {
  reportMarkdown: string;
  rawData: any;
  error?: string;
}

实现模式

• 输入校验：必须提供 instagramHandle 或 websiteDomain 中的至少一个
• 按顺序依次调用各个采集器技能，并传入相应输入参数
• 将各采集结果汇总至一个复合数据对象中
• 以聚合后的数据为输入，调用 report-generator 技能
• 返回最终报告的 Markdown 内容及原始数据

示例用法

const input = { instagramHandle: 'gymshark', websiteDomain: 'gymshark.com' };
const report = await marketingOrchestrator(input);
console.log(report.reportMarkdown);

编排逻辑（伪代码）

async function marketingOrchestrator(input: MarketingInput): Promise {
  if (!input.instagramHandle && !input.websiteDomain) {
    throw new Error("Either instagramHandle or websiteDomain is required");
  }

  const auditData: any = {
    input,
    collectedAt: new Date().toISOString(),
  };

  if (input.instagramHandle) {
    auditData.instagram = await runSkill('instagram-collector', { handle: input.instagramHandle });
  }

  if (input.websiteDomain) {
    auditData.metaAds = await runSkill('meta-ads-collector', { brandName: input.websiteDomain, domain: input.websiteDomain });
    auditData.keywords = await runSkill('seo-collector', { domain: input.websiteDomain });
    auditData.competitors = await runSkill('competitor-finder', { brandName: input.websiteDomain, domain: input.websiteDomain });
    auditData.websiteAudit = await runSkill('website-audit', { domain: input.websiteDomain });
  }

  const report = await runSkill('report-generator', auditData);

  return {
    reportMarkdown: report.reportMarkdown,
    rawData: auditData,
  };
}

备注

• 每次 runSkill 调用均对应于以子代理（sub-agent）或子进程方式调用另一个技能。
• 调用框架需负责管理外部服务所需的 API 密钥与环境变量。
• 单个采集器发生错误时，不应中断整体编排流程。
• 可根据需要扩展支持更多采集器或数据源。