Flux de lucru pentru cercetarea creatorilor Apify + n8n: Construcție pas cu pas

Cercetarea creatorilor ocupă în liniște după-amieze întregi. Derulez pe TikTok, YouTube și Instagram, copiez numărul de vizualizări într-o foaie, apoi pierd singura postare care conta cu adevărat.

O căsuță poștală săptămânală pentru cercetarea creatorilor distruge această rutină.

Apify Actori extrage postările publice ale creatorilor și un flux de lucru de automatizare n8n punctează fiecare postare, semnalează valorile aberante și întreabă un AI model pentru a identifica tipare de cârlige.

Apoi, un rezumat curat ajunge în Gmail în aceeași zi a fiecărei săptămâni, gata înainte de prima cafea.

Mai jos este versiunea completă, nod cu nod, din intrările actorului și logica de notare a implicării la AI rezumate de conținut și alerte de eroare. Nicio teorie, doar un sistem pe care îl poți copia.

AIMOJO's Verdictul rapid

Alegerea actorilor Apify pentru datele creatorilor

Apify Store găzduiește scrapere predefinite numite Actors. Trei dintre ele acoperă majoritatea nevoilor de cercetare ale creatorilor și fiecare prezintă filtre de date care mențin o extragere săptămânală redusă.

Actor	Câmpuri cheie de introducere	Câmpuri de ieșire care merită păstrate
Scraper YouTubestreamere/scraper-youtube	URL-uriDeStart, RezultateMaxime, RezultateMaximeScurte, FluxuriRezultateMaxime, SortareVideoclipuriDupă, DataPostareMaiVeche	titlu, url, dată, număr de vizualizări, aprecieri, număr de comentarii, numecanal, numărDeabonați
TikTok Scraperclockworks/tiktok-scraper	profiluri, rezultatePePagină, sortareprofil, excluderePostăriFixate, cea mai vecheDatăPostareUnificată	text, webVideoUrl, createTimeISO, playCount, diggCount, commentCount, shareCount, collectCount, authorMeta.fans
Instagram Scraperapify/scraper-de-instagram	URL-uri directe, tip rezultate, limită rezultate, doar postăriMai noi decât	legendă, url, cod scurt, marcaj temporal, număr de aprecieri, număr de comentarii, număr de vizualizări video, proprietarNume utilizator

Câteva detalii contează aici. YouTube Scraper's Intervalul de date se aplică numai adreselor URL ale canalelor, iar setarea oricărei limite de tip la 0 omite complet formatul respectiv.

Sortarea profilelor din TikTok Scraper acceptă cele mai recente, populare sau cele mai vechi. Filtrele sale de dată sunt marcate ca filtre taxate pe pagina Actor, așa că verificați acest lucru înainte de a le activa.

Ai nevoie de numărul de urmăritori și biografii pentru Instagram? Adaugă Instagram Profile Scraper (apify/instagram-profile-scraper) cu o matrice de nume de utilizator. Returnează numărul de urmăritori, biografia, datele verificate și cele mai recente postări.

Transcrierile sunt opționale. YouTube Scraper's transcriptionAndSubtitle și TikTok Scraper's Opțiunile de descărcare a subtitrărilor trag cârligele rostite, ceea ce face ca AI note de model mult mai clare.

În interiorul nodului oficial Apify pentru n8n

Apify livrează un nod comunitar verificat, @apify/n8n-nodes-apify. Pe n8n Cloud, căutați „Apify” în panoul de noduri și instalați-l, cu condiția ca nodurile comunitare verificate să fie permise în Panoul de administrare.

Pe un nod n8n auto-găzduit, deschideți Setări > Noduri comunitare , lipiți numele pachetului și instalați-l. Nodul are nevoie de n8n 1.57.0 sau o versiune ulterioară.

Resursă	Operațiuni disponibile	Utilizare în această compilare
Actori	Execută un Actor, execută un Actor și obține setul său de date, Web Fetch, obține cea mai recentă execuție	Etapa principală de răzuire
Sarcinile actorului	Execută o sarcină, execută o sarcină și obține setul său de date	Intrări de curățare salvate în Apify
Execuții de actori	Adu unul, adu mai multe, anulează	Depanare și curățare
Stocare	Obțineți elemente ale setului de date, obțineți înregistrarea magazinului cheie-valoare	Extrageți rezultatele prin implicitDatasetId
trăgaci	La un nou eveniment Apify (Reușit, Eșuat, Abandonat, Expirat, Oricare)	Versiune separată a căsuței poștale pentru liste mari de jucători

Autentificarea funcționează în două moduri. Acreditările API Apify preiau token-ul API din consola Apify, în timp ce API-ul Apify OAuth2 se conectează cu un singur clic doar pe n8n Cloud.

Operația Actor expune și date de intrare personalizate (JSON), timeout în secunde, memorie în megaocteți, etichetă de compilare și așteptare pentru finalizare.

Lăsați câmpul de intrare personalizat gol, iar Actorul va folosi câmpul de intrare implicit salvat.

Ghid pas cu pas pentru fluxul de lucru săptămânal de cercetare a creatorilor

Pasul 1: Configurați lista creatorilor în Foi de calcul Google

Creați o foaie de calcul numită Listă creatori cu aceste coloane. Colegii de echipă pot adăuga sau întrerupe creatori direct din Foi de calcul, fără a deschide vreodată n8n.

Adăugați o a doua filă numită Jurnal postări . Fiecare postare evaluată este scrisă acolo, oferindu-vă un istoric pentru valori de referință mai bune în timp.

Pasul 2: Salvați fiecare scraper ca sarcină Apify Actor

Deschideți fiecare Actor în Consola Apify, setați limite rezonabile și faceți clic pe Salvare ca sarcină nouă.

Sarcinile Apify Actor stochează datele de intrare plus timeout-ul și memoria, astfel încât partea n8n rămâne ordonată.

Dezactivați fiecare comutator pentru descărcare. Fișierele video , coperțile și avatarele adaugă greutate fără a ajuta la cercetare.

Pasul 3: Conectați acreditările Apify, Google Sheets și Gmail

Instalați nodul Apify, apoi adăugați trei acreditări în n8n: Apify API , Google Sheets OAuth2 și Gmail OAuth2 . Testați fiecare acreditări înainte de a continua construirea.

O acreditare nevalidă la jumătatea unui flux de lucru irosește efortul de scraping, așa că această verificare dă roade.

Pasul 4: Configurați declanșatorul de programare n8n

Introduceți un nod declanșator de programare cu aceste setări:

ufld	Valoare
Interval de declanșare	săptămâni
Săptămâni între declanșatoare	1
Declanșator în zilele lucrătoare	luni
Declanșator la oră	7am
Declanșator la minut	0

Setați un fus orar în Setări flux de lucru . Fără unul, n8n revine la fusul orar al instanței, iar instalările auto-găzduite vor fi setate implicit la America/New_York.

Preferi cron? Folosește Personalizat (Cron) cu 0 7 * * 1. În orice caz, declanșatorul de programare n8n se declanșează numai după ce fluxul de lucru este salvat și publicat.

Pasul 5: Construiți intrări pentru platformă cu un nod de cod

Adăugați un nod Foi de calcul Google (Obțineți rânduri, fila Listă de creatori), apoi un nod Cod. Nodul Cod respectiv transformă rândurile listei de operatori într-un singur obiect de intrare per platformă.

const rows = $input.all().map(i => i.json).filter(r => r.active === 'yes');

const since = $now.minus({ days: 7 }).toFormat('yyyy-MM-dd');

const pick = p => rows.filter(r => r.platform === p);

return [{ json: {

  youtube: {

    startUrls: pick('youtube').map(r => ({ url: r.profile_url })),

    maxResults: 15, maxResultsShorts: 15, maxResultStreams: 0,

    sortVideosBy: 'NEWEST', oldestPostDate: since

  },

  tiktok: {

    profiles: pick('tiktok').map(r => r.handle),

    resultsPerPage: 20, profileSorting: 'latest',

    excludePinnedPosts: true, oldestPostDateUnified: since

  },

  instagram: {

    directUrls: pick('instagram').map(r => r.profile_url),

    resultsType: 'posts', resultsLimit: 20, onlyPostsNewerThan: since

  }

}}];

$acum este n8n's dată Luxon încorporată, astfel încât fereastra de șapte zile se derulează automat înainte în fiecare săptămână. Nu este necesară nicio editare manuală a datei, niciodată.

Pasul 6: Executați trei actori Apify în paralel

Ramificați nodul Code în trei noduri Apify. Alegeți resursa Actor Tasks cu operația care execută o sarcină și returnează elementele setului său de date.

În Intrare personalizată, transmiteți obiectul corespondent ca expresie:

{{ JSON.stringify($json.youtube) }}

Repetați cu $json.tiktok și $json.instagram. Introducerea personalizată are prioritate față de introducerea salvată a sarcinii, în timp ce timeout-ul și memoria provin în continuare din sarcina respectivă.

Preferi două noduri separate? Execută Actor cu Wait for finish activat, apoi adaugă elementele Get dataset folosind {{ $json.defaultDatasetId }}. Ambele căi returnează date identice.

Pasul 7: Îmbinarea și normalizarea într-o singură schemă

Conectați toate cele trei noduri Apify la un nod Merge setat la Append. Fiecare platformă denumește câmpurile diferit, astfel încât un nod Code le mapează într-o singură formă partajată.

const out = [];

for (const { json: p } of $input.all()) {

  if (p.error) continue; // skip failed inputs

  if (p.webVideoUrl) {

    out.push({ platform: 'tiktok', post_id: p.id, creator: p.authorMeta?.name,

      url: p.webVideoUrl, caption: p.text, published: p.createTimeISO,

      views: p.playCount, likes: p.diggCount, comments: p.commentCount,

      shares: p.shareCount });

  } else if (p.shortCode) {

    out.push({ platform: 'instagram', post_id: p.shortCode, creator: p.ownerUsername,

      url: p.url, caption: p.caption, published: p.timestamp,

      views: p.videoViewCount ?? null, likes: p.likesCount,

      comments: p.commentsCount, shares: null });

  } else if (p.viewCount !== undefined) {

    out.push({ platform: 'youtube', post_id: p.id, creator: p.channelName,

      url: p.url, caption: p.title, published: p.date,

      views: p.viewCount, likes: p.likes, comments: p.commentsCount,

      shares: null });

  }

}

return out.map(json => ({ json }));

YouTube Scraper scrie elemente de eroare pentru videoclipurile șterse sau canalele lipsă. Verificarea p.error le elimină înainte ca acestea să denatureze scorul.

Pasul 8: Evaluează fiecare postare cu ajutorul calculelor valorilor aberante și ale implicării

Vizualizările brute favorizează conturile mari. Un scor al valorilor aberante ale creatorilor compară fiecare postare cu mediana proprie a creatorului respectiv, astfel încât succesul unui canal mic iese în evidență.

metric	Formulă	Ce îți spune
Scor aberant	vizualizări postare ÷ vizualizări mediane ale creatorului	Cât de mult a depășit o postare propria valoare de referință
Rata de implicare	(aprecieri + comentarii + distribuiri) ÷ vizualizări × 100	Cât de dur au reacționat spectatorii
Soluție de rezervă pentru Instagram	aprecieri la postări ÷ aprecieri mediane ale creatorului	Funcționează pentru postările cu imagini fără număr de vizualizări

const items = $input.all().map(i => i.json);

const base = it => it.views || it.likes || 0;

const groups = {};

for (const it of items) (groups[it.creator] ??= []).push(base(it));

const median = a => { const s = [...a].sort((x, y) => x - y), m = Math.floor(s.length / 2);

  return s.length % 2 ? s[m] : (s[m - 1] + s[m]) / 2; };

return items.map(it => {

  const med = median(groups[it.creator]) || 1;

  const eng = it.views ? ((it.likes || 0) + (it.comments || 0) + (it.shares || 0)) / it.views * 100 : null;

  return { json: { ...it, outlier: +(base(it) / med).toFixed(2),

    engagement: eng === null ? null : +eng.toFixed(2) } };

}).sort((a, b) => b.json.outlier - a.json.outlier);

O săptămână de postări constituie o bază subțire. După câteva săptămâni, citește fila Jurnal postări și calculează medianele din istoricul final.

Pasul 9: Blocați repetițiile cu nodul Eliminare duplicate

Adăugați un nod Eliminare duplicate după scorare. Setați operația la Eliminare elemente procesate în execuțiile anterioare și Păstrați elementele unde valoarea este nouă.

Această deduplicare persistentă împiedică un retrigger manual să trimită aceleași postări de două ori prin e-mail. Ștergerea istoricului deduplicării o resetează în timpul testării.

Pasul 10: Adăugați AI Stratul de analiză a modelelor

Folosește un nod Limită pentru a păstra primele 15 postări, apoi un nod Agregat setat la Toate datele articolelor. Aceasta predă întregul lot către AI ca un singur element.

Apoi, adaugă un lanț LLM de bază cu orice model de chat pe care îl folosești deja, cum ar fi OpenAI, Anthropic sau Gemini.

Activați „Solicită un format de ieșire specific” și atașați un analizor structurat de ieșire.

Ești un strateg de conținut pentru texte scurte.

Mai jos sunt din această săptămână's postările creatorilor de top ca JSON, clasificate în funcție de scorul aberant.

Returnează JSON cu:

– „modele”: 3 hook-uri sau formate recurente, fiecare citând adrese URL ale postărilor

– „subiecte”: subiecte care apar în 2+ postări câștigătoare

– „idei”: 3 idei de conținut pe care echipa noastră le poate filma săptămâna aceasta

Folosește doar dovezi din date. Dacă un model este slab, spune-l.

{{ JSON.stringify($json.data) }}

Subtitrările singure nu includ replicile vocale, care de obicei determină un videoclip scurt.'s soarta.

Cu transcrierile activate în sarcina YouTube sau TikTok, transferă primele rânduri ale textului subtitrării în elementul normalizat.

Reduceți textul la aproximativ primele 300 de caractere. Modelul compară apoi primele rânduri reale între câștigători, iar utilizarea tokenurilor rămâne mică.

Replica „folosiți doar dovezi” contează. Menține AI conţinut analiză de tipare ancorată în postări reale în loc de discuții generice despre tendințe.

Pasul 11: Asamblați rezumatul HTML și trimiteți-l prin Gmail

Un nod de cod final împerechează postările evaluate cu AI ieșirea și construiește corpul e-mailului:

const posts = $('Limit').all().map(i => i.json);

const ai = ('BasicLLMChain').first().json.output;constrows=posts.map(p=>`<tr><td>{p.platform}</td><td>p.creator</td><td><ahref="{p.url}">(p.caption||'').slice(0,70)</a></td><td>{p.outlier}x</td><td>p.engagement??'–'%</td></tr>`).join('');consthtml=`<h2>TopOutliers</h2><tableborder="1"cellpadding="6">{rows}</table>

  <h2>Patterns</h2><ul>${ai.patterns.map(x => `<li>${x}</li>`).join('')}</ul>

  <h2>Ideas</h2><ul>${ai.ideas.map(x => `<li>${x}</li>`).join('')}</ul>`;

return [{ json: { html } }];const items = $input.all().map(i => i.json);

const base = it => it.views || it.likes || 0;

const groups = {};

for (const it of items) (groups[it.creator] ??= []).push(base(it));

const median = a => { const s = [...a].sort((x, y) => x - y), m = Math.floor(s.length / 2);

  return s.length % 2 ? s[m] : (s[m - 1] + s[m]) / 2; };

return items.map(it => {

  const med = median(groups[it.creator]) || 1;

  const eng = it.views ? ((it.likes || 0) + (it.comments || 0) + (it.shares || 0)) / it.views * 100 : null;

  return { json: { ...it, outlier: +(base(it) / med).toFixed(2),

    engagement: eng === null ? null : +eng.toFixed(2) } };

}).sort((a, b) => b.json.outlier - a.json.outlier);

Apoi adăugați un nod Gmail cu aceste setări:

Pasul 12: Înregistrați postările în Foi de calcul Google și publicați-le

Ramifică-te de la nodul Eliminare duplicate într-un nod Foi de calcul Google folosind Adăugare sau Actualizare rând din fila Jurnal postări. Potrivește pe post_id, astfel încât statisticile actualizate să suprascrie rândurile mai vechi.

Setați maparea la Mapă automată , deoarece numele câmpurilor normalizate se potrivesc deja cu coloanele. Executați o dată manual, verificați e-mailul, apoi publicați fluxul de lucru.

Scalarea cu ajutorul programărilor Apify și al declanșatoarelor de evenimente

Un singur flux de lucru programat se potrivește unor liste de câteva zeci de creatori. Dincolo de asta, joburile lungi de scraping mențin execuțiile n8n deschise timp de minute, iar o platformă lentă blochează restul.

Remedierea împarte munca pe ambele platforme:

Factor	Flux de lucru unic	Flux de lucru divizat
Timp de configurare	Mai rapid	Puțin mai lung
Lucrări lungi de răzuire	Execuția așteaptă pe tot parcursul	Nu se mai așteaptă în interiorul n8n
O platformă eșuează	Poate bloca digestul	Alții încă aterizează
Nevoi auto-găzduite	Niciun extra	URL-ul WEBHOOK public pentru declanșator

Noile programări Apify încep dezactivate, așa că activați-le după salvare. Apify vă trimite și un e-mail atunci când o sarcină programată nu pornește.

Unde creatorii de scraping ating limite reale

Fiecare prezentare de automatizare omite această parte, așa că iată-o clar.

Tratează inbox-ul ca pe un asistent de cercetare , nu ca pe un oracol. Un om decide în continuare ce model merită o zi de filmare.

Răspunsuri rapide despre cercetarea creatorilor Apify și n8n

Concluzie

Cercetarea creatorilor recompensează pe oricine observă primul un model. Derularea manuală face din aceasta o sarcină cu normă întreagă, iar majoritatea echipelor renunță în liniște după câteva săptămâni.

Apify și n8n predau această treabă unui sistem.

Actorii din magazin extrag postări publice noi, iar nodurile de cod le evaluează pentru fiecare creator.'s propria bază și o AI strat transformă numerele în slipuri.

Începeți cu un singur flux de lucru programat și cinci creatori pe care îi urmăriți deja. Odată ce rezumatul se dovedește util, măriți lista și treceți la configurația divizată cu Apify Schedules.

Dă-i trei sau patru săptămâni de istoric înregistrat. Asta's când scorurile aberante se accentuează și inbox-ul tău de luni începe să depășească orice raport de tendințe pe care l-ai putea cumpăra.