artenis.alija
ende
Alle Projekte
n8n-WorkflowsOpen-Source-Projekt

n8n-B2B-Leadgenerierungs-Pipeline

Elf n8n-Workflows: Leads aus Google Maps, LLM-Recherche pro Firma, verifizierte Kontakte und eine E-Mail-Sequenz in vier Schritten mit Antwortverarbeitung.

Quellcode-Repositories

Quellcode ansehen

n8n-Workflows

Jedes Diagramm wird aus dem JSON des Workflows gezeichnet. Datei herunterladen, in n8n importieren (Workflows → Import from file) und eigene Zugangsdaten hinterlegen – alle Zugangsdaten und Instanz-IDs wurden entfernt.

01 — Sourcing (GMaps daily)

10 nodes · 10 connections

Download JSON
Daily 03:00 TriggerCRONDaily 03:00 TriggerLoad Niche Queries{ }Load Niche QueriesSplit QueriesLOOPSplit QueriesScrape Google MapsHTTPScrape Google MapsFlatten Results{ }Flatten ResultsSplit ResultsLOOPSplit ResultsCheck Domain ExistsPGCheck Domain ExistsIs New Domain?IFIs New Domain?Insert New LeadPGInsert New LeadAlready Exists (skip)—Already Exists (ski…
  • Trigger
  • Code
  • Logic
  • HTTP
  • Database

02 — Enrichment (every 10 min)

17 nodes · 17 connections

Download JSON
Every 10 MinCRONEvery 10 MinFetch 5 New LeadsPGFetch 5 New LeadsSplit LeadsLOOPSplit LeadsAttach Timestamp{ }Attach TimestampRead RPM WindowPGRead RPM WindowCheck Throttle{ }Check ThrottleIs Throttled?IFIs Throttled?Skip (rate limited)—Skip (rate limited)Scrape WebsiteHTTPScrape WebsiteExtract Signals{ }Extract SignalsBuild Groq Prompt{ }Build Groq PromptCall Groq 8BHTTPCall Groq 8BParse Groq Response{ }Parse Groq ResponseUpdate Lead RowPGUpdate Lead RowPrepare Contacts{ }Prepare ContactsInsert ContactsPGInsert ContactsUpdate RPM CounterPGUpdate RPM Counter
  • Trigger
  • Database
  • Logic
  • Code
  • HTTP

02b — Qualification Gate

13 nodes · 16 connections

Download JSON
Every 10 Min (+2 offset)CRONEvery 10 Min (+2 of…Fetch Enriched LeadsPGFetch Enriched LeadsSplit LeadsLOOPSplit LeadsEnglish Check{ }English CheckEnglish Pass?IFEnglish Pass?Disqualify: Not EnglishPGDisqualify: Not Eng…Compute Size ScoreHTTPCompute Size ScoreAttach Size Score{ }Attach Size ScoreSize Pass?IFSize Pass?Disqualify: Too SmallPGDisqualify: Too Sma…Fit Score >= 4?IFFit Score >= 4?Disqualify: Low FitPGDisqualify: Low FitSet QualifiedPGSet Qualified
  • Trigger
  • Database
  • Logic
  • Code
  • HTTP

02c — Opportunity Research (70B)

12 nodes · 12 connections

Download JSON
Every 15 MinCRONEvery 15 MinFetch Qualified No ResearchPGFetch Qualified No …Split LeadsLOOPSplit LeadsRead RPM WindowPGRead RPM WindowCheck Throttle{ }Check ThrottleIs Throttled?IFIs Throttled?Skip (throttled)—Skip (throttled)Build 70B Research Prompt{ }Build 70B Research …Call Groq 70BHTTPCall Groq 70BParse + Validate{ }Parse + ValidateStore Research ArtifactPGStore Research Arti…Update RPM CounterPGUpdate RPM Counter
  • Trigger
  • Database
  • Logic
  • Code
  • HTTP

03 — Contact Discovery + Email Verify

18 nodes · 19 connections

Download JSON
Every 15 MinCRONEvery 15 MinFetch Leads Needing ContactsPGFetch Leads Needing…Split LeadsLOOPSplit LeadsLoad Existing C-LevelPGLoad Existing C-Lev…Count C-Level Contacts{ }Count C-Level Conta…Has 2+ C-Level?IFHas 2+ C-Level?Google: LinkedIn C-Level SearchHTTPGoogle: LinkedIn C-…Registry LookupHTTPRegistry LookupMerge + Dedupe Contacts{ }Merge + Dedupe Cont…Split ContactsLOOPSplit ContactsGenerate Email Permutations{ }Generate Email Perm…Split Permutations{ }Split PermutationsVerify Email via ReacherHTTPVerify Email via Re…Score Email Result{ }Score Email ResultPick Best Email{ }Pick Best EmailAssign Primary Contact{ }Assign Primary Cont…Upsert ContactPGUpsert ContactSkip (enough contacts)—Skip (enough contac…
  • Trigger
  • Database
  • Logic
  • Code
  • HTTP

04a — Outreach Touch 1 (Day 0)

22 nodes · 23 connections

Download JSON
Weekdays 09:00CRONWeekdays 09:00Read Send StatePGRead Send StateCheck Daily Cap{ }Check Daily CapAt Cap?IFAt Cap?Stop (daily cap reached)—Stop (daily cap rea…Fetch Sendable LeadsPGFetch Sendable LeadsBuild Touch 1 Prompt{ }Build Touch 1 PromptGenerate EmailHTTPGenerate EmailParse Email Output{ }Parse Email OutputNEEDS_HUMAN?IFNEEDS_HUMAN?Telegram: NEEDS_HUMAN AlertHTTPTelegram: NEEDS_HUM…Validate: No-Money + No-AI-Tells{ }Validate: No-Money …Validation Passed?IFValidation Passed?Can Regen?IFCan Regen?Increment Regen Counter{ }Increment Regen Cou…Telegram: Escalate Validation FailHTTPTelegram: Escalate …Append Signature{ }Append SignatureSend via GmailMAILSend via GmailInsert email_sendsPGInsert email_sendsUpdate Lead: ContactedPGUpdate Lead: Contac…Increment Send CounterPGIncrement Send Coun…Telegram: Email SentTGTelegram: Email Sent
  • Trigger
  • Database
  • Code
  • Logic
  • HTTP
  • Messaging

04b — Outreach Touch 2 (Day +4)

14 nodes · 17 connections

Download JSON
Weekdays 09:05CRONWeekdays 09:05Fetch Touch 2 Ready LeadsPGFetch Touch 2 Ready…Split LeadsLOOPSplit LeadsBuild Touch 2 Prompt{ }Build Touch 2 PromptGenerate Touch 2HTTPGenerate Touch 2Parse Output{ }Parse OutputNEEDS_HUMAN?IFNEEDS_HUMAN?Validate{ }ValidateValidation Passed?IFValidation Passed?Can Regen?IFCan Regen?Increment Regen{ }Increment RegenAppend Signature{ }Append SignatureSend via GmailMAILSend via GmailInsert email_sendsPGInsert email_sends
  • Trigger
  • Database
  • Logic
  • Code
  • HTTP
  • Messaging

04c — Outreach Touch 3 (Day +9, secondary contact)

12 nodes · 14 connections

Download JSON
Weekdays 09:10CRONWeekdays 09:10Fetch Touch 3 Ready LeadsPGFetch Touch 3 Ready…Split LeadsLOOPSplit LeadsBuild Touch 3 Prompt{ }Build Touch 3 PromptGenerate Touch 3HTTPGenerate Touch 3Parse Output{ }Parse OutputNEEDS_HUMAN?IFNEEDS_HUMAN?Validate{ }ValidateValidation Passed?IFValidation Passed?Append Signature{ }Append SignatureSend via GmailMAILSend via GmailInsert email_sendsPGInsert email_sends
  • Trigger
  • Database
  • Logic
  • Code
  • HTTP
  • Messaging

04d — Outreach Touch 4 (Day +14, soft close)

7 nodes · 7 connections

Download JSON
Weekdays 09:15CRONWeekdays 09:15Fetch Touch 4 Ready LeadsPGFetch Touch 4 Ready…Split LeadsLOOPSplit LeadsBuild Soft Close (Fixed Template){ }Build Soft Close (F…Send via GmailMAILSend via GmailInsert email_sendsPGInsert email_sendsUpdate Lead: Closed No ResponsePGUpdate Lead: Closed…
  • Trigger
  • Database
  • Logic
  • Code
  • Messaging

05 — Reply Handler

33 nodes · 35 connections

Download JSON
Gmail Push WebhookHOOKGmail Push WebhookDecode Pub/Sub Message{ }Decode Pub/Sub Mess…Fetch Gmail HistoryHTTPFetch Gmail HistoryExtract New Message IDs{ }Extract New Message…Split MessagesLOOPSplit MessagesFetch Full MessageHTTPFetch Full MessageExtract Reply Body{ }Extract Reply BodyMatch to LeadPGMatch to LeadLead Matched?IFLead Matched?Unmatched Reply (ignore)—Unmatched Reply (ig…Build Classification Prompt{ }Build Classificatio…Classify Reply (8B)HTTPClassify Reply (8B)Parse Classification{ }Parse ClassificationIs Unsubscribe?IFIs Unsubscribe?Auto-Reply: UnsubscribeMAILAuto-Reply: Unsubsc…Mark Closed LostPGMark Closed LostRead reply_modePGRead reply_modeBuild Draft Reply Prompt{ }Build Draft Reply P…Use Fixed Template?IFUse Fixed Template?Draft Reply (70B)HTTPDraft Reply (70B)Parse Draft{ }Parse DraftPrepare Telegram Approval{ }Prepare Telegram Ap…Phase B?IFPhase B?Auto-sendable Class?IFAuto-sendable Class?Send to Telegram for ApprovalHTTPSend to Telegram fo…Insert email_repliesPGInsert email_repliesUpdate Lead: RepliedPGUpdate Lead: RepliedTelegram Callback WebhookHOOKTelegram Callback W…Action is Send or Edit?IFAction is Send or E…Fetch Reply RecordPGFetch Reply RecordPrepare Approved Send{ }Prepare Approved Se…Send Approved ReplyMAILSend Approved ReplyMark Reply SentPGMark Reply Sent
  • Trigger
  • Code
  • HTTP
  • Logic
  • Database
  • Messaging

06 — Booking to Brief (Telegram)

14 nodes · 13 connections

Download JSON
Cal.com Booking WebhookHOOKCal.com Booking Web…Parse Cal.com Payload{ }Parse Cal.com Paylo…Fetch Lead by EmailPGFetch Lead by EmailFetch Email ThreadPGFetch Email ThreadBuild Brief Prompt{ }Build Brief PromptGenerate Brief (70B)HTTPGenerate Brief (70B)Extract Brief{ }Extract BriefSend Brief to TelegramTGSend Brief to Teleg…Insert BookingPGInsert BookingUpdate Lead: BookedPGUpdate Lead: BookedCompute Reminder Wait{ }Compute Reminder Wa…Wait Until 1h Before MeetingWAITWait Until 1h Befor…Send ReminderTGSend ReminderMark Reminder SentPGMark Reminder Sent
  • Trigger
  • Code
  • Database
  • HTTP
  • Messaging
  • Logic

Projektübersicht

Elf n8n-Workflows: Leads aus Google Maps, LLM-Recherche pro Firma, verifizierte Kontakte und eine E-Mail-Sequenz in vier Schritten mit Antwortverarbeitung. Die Workflows sind bereinigt und können direkt heruntergeladen und in eine eigene n8n-Instanz importiert werden.

Was ich gebaut habe

  1. 01

    Recherche, Anreicherung, Qualifizierung und Analyse laufen als getrennte, geplante Workflows mit einer gemeinsamen Postgres-Zustandsmaschine.

  2. 02

    Die Kontaktsuche findet die zuständige Entscheidungsperson und prüft die Adresse, bevor etwas versendet wird.

  3. 03

    Vier Kontaktpunkte an Tag 0, 4, 9 und 14; der Buchungslink erscheint erst im letzten oder nach einer interessierten Antwort.

  4. 04

    Der Antwort-Workflow ordnet Rückmeldungen ein und entwirft Antworten, die vor dem Versand per Telegram freigegeben werden.

Technische Umsetzung

Jede Stufe ist ein eigener Workflow: Fällt ein Scraper oder Modellaufruf aus, stockt nur diese Stufe, und keine Leads gehen verloren.

Läuft mit Groq (LLaMA 3.3 70B), Gmail OAuth, Telegram, Playwright und Reacher auf einem einzigen selbst gehosteten VPS.

Technologie-Stack

  • n8n
  • PostgreSQL
  • Groq
  • LLaMA 3.3 70B
  • Gmail
  • Telegram
  • Playwright

Weitere Open-Source-Projekte

Open-Source-Datenplattform

Open Job Board EU

Projekt ansehen Kostenloses Browser-Videotool

HTML-zu-MP4-Konverter

Projekt ansehen Datenschutzorientiertes PDF-Toolkit

Open PDF Converter

Projekt ansehen

Sie benötigen ein ähnliches Produkt?

Lassen Sie uns über den Workflow, die Website oder die Anwendung sprechen, die Sie veröffentlichen möchten.

Projekt starten