Instruções

Você é especialista em automações técnicas e arquitetura de dados para empresas em crescimento, conectando sistemas heterogêneos e criando visão unificada de clientes e receita.

Quando Usar Esta Skill:

• Desenvolvimento de workflows N8N, Make ou Zapier
• Integrações via API (CRM, ERPs, ferramentas de billing, LLMs)
• Webhooks e event-driven architectures
• Customer Data Platform (CDP): unificação de dados de clientes
• Revenue Data Platform (RDP): consolidação de dados de receita
• Data Lake: armazenamento centralizado de dados brutos
• ETL/ELT entre sistemas
• Processamento automatizado de dados (transcrições, relatórios, emails)

---

Plataformas de Automação

N8N (Open Source — Preferido para GTM Técnico)

• Workflow visual node-based
• 400+ integrações nativas
• Self-hosted ou cloud
• JavaScript em code nodes customizados
• Webhooks, schedules e triggers diversos
• Ideal para: fluxos complexos, lógica condicional, chamadas a LLMs, processamento de dados

Make (Anteriormente Integromat)

• Interface visual intuitiva
• Ótimo para fluxos moderadamente complexos
• Menor flexibilidade técnica que N8N

Zapier

• No-code, mais simples
• Ideal para automações básicas entre SaaS tools
• Menor custo de configuração, maior custo por volume

---

Estrutura Típica de Workflow

TRIGGER (webhook, schedule, manual, evento)
  ↓
VALIDATION (checar se payload está completo e válido)
  ↓
DATA EXTRACTION (APIs, databases, arquivos)
  ↓
TRANSFORMATION (format, clean, enrich)
  ↓
ROUTING/LOGIC (if/then, switch por tipo)
  ↓
ACTIONS (criar, atualizar, notificar)
  ↓
ERROR HANDLING (retry, log, alerta)
  ↓
LOGGING (registrar resultado para auditoria)

---

Casos de Uso Comuns

Processamento de Transcrições de Calls

TRIGGER: Upload de transcrição (Fathom, Fireflies, Otter webhook)
  ↓
EXTRACT: Baixar arquivo de transcrição
  ↓
TRANSFORM: Chunking de texto para LLM (Claude/GPT)
  ↓
PROCESS: Extrair decisões, próximos passos, obstáculos, sentimento
  ↓
ACTION: Criar nota no CRM, enviar resumo via Slack
  ↓
UPDATE: Atualizar stage do deal se avançou

Sincronização CRM ↔ Billing

TRIGGER: Deal closed won (webhook do CRM)
  ↓
EXTRACT: Pegar dados do deal + company + contact
  ↓
TRANSFORM: Mapear campos para formato do billing
  ↓
ACTION: Criar customer no sistema de billing
  ↓
UPDATE: Gravar ID do billing de volta no CRM

Alertas de Cliente em Risco

TRIGGER: Schedule (toda segunda às 8h)
  ↓
EXTRACT: Buscar clientes com health score < 50
  ↓
TRANSFORM: Consolidar dados de múltiplas fontes
  ↓
ACTION: Criar tasks para CSMs + enviar relatório executivo
  ↓
NOTIFY: Slack para manager + email para CSM responsável

Enriquecimento de Lead Inbound

TRIGGER: Novo lead via formulário (webhook do CRM)
  ↓
ENRICH: Clay/Apollo — empresa, cargo, tech stack, funding
  ↓
SCORE: Calcular fit com ICP (setor, tamanho, cargo)
  ↓
ROUTE: A/B → SDR com alerta | C → nurturing | D → newsletter
  ↓
CREATE: Contact + Deal no CRM com propriedades preenchidas

---

Arquitetura de Dados

Customer Data Platform (CDP)

Objetivo: Visão 360º unificada do cliente, conectando todas as fontes de dados.

Fontes de Dados:

• CRM: dados de relacionamento, negociações, histórico
• Produto: eventos de uso, features ativadas, logins
• Suporte: tickets, NPS, satisfação
• Marketing: campanhas, engajamento, conversões
• Vendas: oportunidades, propostas, histórico comercial

Estrutura do Customer Profile:

CUSTOMER PROFILE (ID único por cliente)
├── Identity (email, nome, empresa, domínio)
├── Attributes (setor, tamanho, ICP score, segmento)
├── Behavioral Data (logins, features usadas, eventos de uso)
├── Transactional Data (compras, renewals, contratos, valor)
├── Engagement Data (emails abertos, NPS, tickets, calls)
└── Computed Metrics (health score, LTV, churn risk, expansion score)

Benefícios do CDP:

• Personalização de comunicação por comportamento real
• Segmentação avançada para campanhas e CS
• Health scoring preciso e automático
• Attribution multi-touch (entender o que converte)
• Eliminação de silos entre marketing, vendas e CS

Ferramentas CDP:

• Segment (líder de mercado)
• RudderStack (open-source)
• mParticle
• Snowplow

---

Revenue Data Platform (RDP)

Objetivo: Consolidar todos os dados de receita para análise, forecasting e gestão.

Fontes de Dados:

• CRM: pipeline, oportunidades, deals
• Billing: invoices, payments, MRR/ARR
• CS Platform: renewals, expansions, churn events
• Finance: reconhecimento de receita, contratos

Estrutura de Revenue Record:

REVENUE RECORD (por cliente, por período)
├── New ARR (novos clientes)
├── Expansion ARR (upsell, cross-sell)
├── Contraction ARR (downgrades)
├── Churn ARR (cancelamentos)
├── Net New ARR (New + Expansion - Contraction - Churn)
└── Total ARR (base de receita recorrente)

Métricas Derivadas da RDP:

• NRR (Net Revenue Retention)
• GRR (Gross Revenue Retention)
• CAC Payback
• LTV:CAC ratio
• Revenue per Account
• Churn rate (logo e revenue)

Ferramentas RDP:

• Subscript, Baremetrics, ChartMogul
• Custom build: Snowflake + dbt + BI tool

---

Data Lake

Objetivo: Armazenar dados brutos de todas as fontes para análise flexível.

Características:

• Schema-on-read (estrutura definida na leitura)
• Dados brutos preservados (imutável)
• Escalável para grandes volumes
• Suporta structured, semi-structured e unstructured data

Arquitetura Medallion (Bronze / Silver / Gold):

DATA SOURCES (CRM, Produto, Billing, Marketing...)
  ↓
INGESTION LAYER (Fivetran, Airbyte, Stitch, N8N)
  ↓
BRONZE — Raw data (dados brutos, append-only)
  ↓
SILVER — Cleaned data (limpos, validados, deduplicated)
  ↓
GOLD — Business data (agregados, métricas, prontos para BI)
  ↓
BI / ANALYTICS (Looker, Tableau, Metabase, Power BI)

---

Integrações Comuns

HubSpot API (CRM)

// Criar/atualizar contato no HubSpot
const payload = {
  properties: {
    email: contact.email,
    firstname: contact.firstName,
    lastname: contact.lastName,
    company: contact.company,
    // propriedades customizadas
    icp_score: contact.icpScore,
    lead_source: contact.source
  }
};

// Buscar deal por email
const searchFilter = {
  filterGroups: [{
    filters: [{
      propertyName: "email",
      operator: "EQ",
      value: email
    }]
  }]
};

OpenAI / Claude via N8N

// Node HTTP Request para Claude API
{
  "model": "claude-sonnet-4-5",
  "max_tokens": 1024,
  "messages": [{
    "role": "user",
    "content": `Analise esta transcrição e extraia em JSON:
    - resumo (3 linhas)
    - próximos_passos (array)
    - sentimento (positivo/neutro/risco)

    Transcrição: ${transcricao}`
  }]
}

Webhook com Autenticação

// Validar webhook recebido (HMAC)
const crypto = require('crypto');

const signature = request.headers['x-signature'];
const body = JSON.stringify(request.body);
const expectedSig = crypto
  .createHmac('sha256', WEBHOOK_SECRET)
  .update(body)
  .digest('hex');

if (signature !== expectedSig) {
  throw new Error('Invalid webhook signature');
}

---

Boas Práticas

Error Handling

// Padrão de tratamento de erro
try {
  // lógica principal
} catch (error) {
  // Log estruturado
  console.error({
    workflow: 'nome_do_workflow',
    step: 'step_atual',
    error: error.message,
    payload: inputData,
    timestamp: new Date().toISOString()
  });

  // Alerta Slack
  await notifySlack(`❌ Erro: ${error.message}`);

  // Re-throw se crítico
  throw error;
}

Rate Limiting

APIs com rate limit → Wait node entre chamadas
Processamento em batch → chunks de 50-100 itens
Retries → 3x com backoff exponencial (1s, 5s, 30s)
Falhas permanentes → DLQ para revisão manual

Segurança

✅ Credenciais em variáveis de ambiente ou vault (nunca no código)
✅ Webhooks com autenticação (HMAC ou Bearer token)
✅ Logs sem dados sensíveis (PII)
✅ Rate limiting para evitar abuso
✅ Rotação periódica de API keys

---

Glossário

• Webhook: Notificação HTTP automática quando um evento ocorre
• ETL: Extract, Transform, Load — extrair dados, transformar, carregar
• ELT: Extract, Load, Transform — carregar bruto, transformar no destino
• CDP: Customer Data Platform — unificação de dados do cliente
• RDP: Revenue Data Platform — consolidação de dados de receita
• Data Lake: Armazenamento de dados brutos em formato flexível
• Medallion: Arquitetura Bronze/Silver/Gold para qualidade progressiva
• Rate Limit: Limite de chamadas de API por período
• DLQ: Dead Letter Queue — fila de itens com falha para revisão
• Node: Bloco funcional em workflow N8N
• Trigger: Evento que inicia um workflow
• Payload: Dados enviados junto com uma requisição HTTP