n8n कनेक्टर

n8n के लिए Entity Enricher कम्युनिटी नोड आपको विज़ुअल ड्रैग-एंड-ड्रॉप एडिटर के साथ स्वचालित एनरिचमेंट पाइपलाइन बनाने देता है। बिना कोड लिखे 400+ ऐप्स से कनेक्ट करें।

इंस्टॉलेशन

अपने n8n इंस्टेंस में कम्युनिटी नोड इंस्टॉल करें:

npm install n8n-nodes-entity-enricher

या n8n UI के माध्यम से इंस्टॉल करें: Settings → Community Nodes पर जाएँ और n8n-nodes-entity-enricher खोजें।

पूर्वापेक्षाएँ

API कुंजी— Entity Enricher में एक organization एक्सेस की बनाएँ। विवरण के लिए API Keys दस्तावेज़ देखें। की का प्रारूप ent_XXXXXXXXXXXX है।
बेस URL— आपके Entity Enricher इंस्टेंस का URL (जैसे, https://entityenricher.ai या आपका सेल्फ-होस्टेड URL)।
क्रेडेंशियल सेटअप— n8n में, अपनी API key और base URL के साथ एक Entity Enricher API credential बनाएं। सभी nodes इसी credential का उपयोग करेंगे। एक organization access key किसी भी user account से स्वतंत्र रूप से कार्य करती है — टिकाऊ service-to-service workflows के लिए यही अनुशंसा है।
OAuth2 (विकल्प)— अपने account से कनेक्ट करना पसंद करेंगे? इसके बजाय एक Entity Enricher OAuth2 API credential बनाएं: n8n द्वारा दिखाया गया OAuth redirect URL कॉपी करें, इसके साथ Entity Enricher में API Keys → Connected Apps → OAuth Clients (owner role) के अंतर्गत एक OAuth client पंजीकृत करें, client ID को n8n में पेस्ट करें, और Connect my account पर क्लिक करें। यह connection आपकी अपनी role के साथ कार्य करता है और इसे कभी भी Connected Apps के अंतर्गत रद्द किया जा सकता है। node पर उसके Authentication parameter के साथ credential चुनें।
  1. 1Connected Apps में दिखने वाला नाम
  2. 2n8n का OAuth रीडायरेक्ट URL, हूबहू कॉपी किया हुआ
  3. 3n8n में पेस्ट करने के लिए क्लाइंट ID देता है
क्लाइंट को बाद में एडिट नहीं किया जा सकता — इसका रीडायरेक्ट URL बनाते समय ही तय हो जाता है, इसलिए दूसरे n8n इंस्टेंस को अपना अलग क्लाइंट मिलता है, और किसी एक को हटाते ही उसके ज़रिए बने हर कनेक्शन तुरंत रद्द हो जाते हैं।

उपलब्ध ऑपरेशन

कनेक्टर 7 रिसोर्स श्रेणियों में 18 ऑपरेशन उपलब्ध कराता है:

रिसोर्सऑपरेशनविवरण
EnrichmentEnrich Entityएक अकेली entity को enrich करें — बस एक schema चुनें; आपके organization का सबसे अच्छा model और strategy अपने-आप चुन लिए जाते हैं। रियल-टाइम प्रोग्रेस के साथ SSE के ज़रिए रिज़ल्ट स्ट्रीम करता है।
EnrichmentEnrich Entity Advancedmodels, fusion, strategy, classification और structured output पर पूरे नियंत्रण के साथ एक अकेली entity को enrich करें।
EnrichmentBatch Enrichसभी input आइटम्स को ऑटोमैटिक model और strategy के साथ एक ही batch के रूप में enrich करें। प्रति-entity प्रोग्रेस ट्रैकिंग के साथ पैरेलल प्रोसेसिंग।
EnrichmentBatch Enrich Advancedसभी input आइटम्स को पूरे पैरामीटर सेट के साथ एक ही batch के रूप में enrich करें।
SchemaList Schemasसंवर्धन वर्कफ़्लो में चयन के लिए उपलब्ध सहेजे गए स्कीमा की सूची बनाएँ।
SchemaGet Schema Detailsकिसी विशिष्ट schema के लिए निकाली गई मुख्य प्रॉपर्टीज़ के साथ पूर्ण schema सामग्री प्राप्त करें।
SchemaGenerate Sampleएक ही जॉब में एक एंटिटी टाइप के 1..N यथार्थवादी सैंपल JSON ऑब्जेक्ट जनरेट करें — स्कीमा-लेखन लूप का प्रवेश-बिंदु। भाषा डिफ़ॉल्ट रूप से auto रहती है, जो आपकी अपनी रिक्वेस्ट के शब्दों से अनुमानित होती है।
SchemaGenerate SchemaJSON स्कीमा जनरेट करके अपने-आप सेव करें — हर इनपुट आइटम एक ही एंटिटी टाइप का एक सैंपल है: फ़ील्ड्स का यूनियन, जहाँ कोई फ़ील्ड किसी सैंपल में मौजूद नहीं वहाँ nullable, और उदाहरण के रूप में असल में देखे गए मान। Language विकल्प तय करता है कि स्कीमा खुद को किस भाषा में वर्णित करेगा।
RecordList Recordsटाइप और सफलता फ़िल्टर के साथ enrichment record क्वेरी करें। पेजिनेटेड परिणाम।
RecordGet Recordपूर्ण संरचित आउटपुट के साथ ID द्वारा एक विशिष्ट enrichment परिणाम प्राप्त करें।
RecordSync Records to Databaseसंग्रहीत (या रूपांतरित) एनरिचमेंट आउटपुट को उसके स्कीमा के database sync पर भेजें — प्रकाशित कॉन्ट्रैक्ट के विरुद्ध दोबारा सत्यापित, फिर एडमिशन गेट से गुज़ारा गया।
FusionMerge Resultsवैकल्पिक LLM आर्बिट्रेशन के साथ कई संवर्धन रिकॉर्ड के परिणामों को फ्यूज़ करें।
AttachmentAdd Attachmentइनपुट आइटम से एक या अधिक बाइनरी फ़ाइलें अपलोड करें (एकल मल्टीपार्ट रिक्वेस्ट) और प्रति अटैचमेंट ID एक आइटम लौटाएँ।
AttachmentDelete AttachmentID द्वारा एक attachment हटाएँ — enrichment के बाद सफ़ाई का एक सुविधाजनक चरण।
Database SyncList Database Syncsकिसी स्कीमा पर पंजीकृत database sync की सूची दें, लंबित डेल्टा गिनती के साथ।
Database SyncFetch Deltasडेटाबेस डेल्टा की अगली FIFO विंडो (SQL + JSON) प्राप्त करें, वैकल्पिक रूप से स्वीकृति के लिए उन्हें लीज़ पर लेते हुए।
Database SyncAcknowledge Deltasकिसी ID तक लागू किए गए डेल्टा को स्वीकार करें — यह लीज़ को रिलीज़ करता है और, sync विकल्पों के अनुसार, डिलीवर की गई प्रतियाँ हटा देता है।
ConfigurationGet Optionsडायनामिक कॉन्फ़िगरेशन के लिए उपलब्ध मॉडल, भाषाएँ, स्ट्रैटेजी और प्लान सीमाएँ फ़ेच करें।

ट्रिगर नोड

पैकेज में एक अलग Entity Enricher Trigger नोड भी आता है — एक webhook ट्रिगर जो किसी भी प्लेटफ़ॉर्म इवेंट पर वर्कफ़्लो शुरू करता है और अपनी सब्सक्रिप्शन अपने आप रजिस्टर कर लेता है। इसका Event ड्रॉपडाउन आपके अकाउंट से लाइव लोड होता है, इसलिए प्लेटफ़ॉर्म द्वारा भेजा जाने वाला हर इवेंट नोड को अपडेट किए बिना उपलब्ध रहता है:

एनरिचमेंट रिकॉर्ड— record.created हर पूर्ण एनरिचमेंट पर फ़ायर होता है (Database Sync के साथ या उसके बिना)। वैकल्पिक रूप से इसे एक स्कीमा तक सीमित करें। जो रन किसी Database Sync के एडमिशन गेट में विफल हुआ हो, वह database.saved = false और छूटे हुए आवश्यक फ़ील्ड की सूची के साथ आता है।
खाते, बिलिंग और क्रेडिट— member.*, subscription.*, credits.* — जॉइन रिक्वेस्ट, रोल में बदलाव, प्लान अपग्रेड, क्रेडिट खरीद, या कम/समाप्त बैलेंस। हर "updated" इवेंट के साथ एक changes मैप आता है जो बताता है कि ठीक कौन-सा एट्रिब्यूट बदला है।
जॉब और स्कीमा— किसी भी LLM job के लिए job.completed / job.failed — एनरिचमेंट, बैच, बेंचमार्क, सैंपल या स्कीमा जनरेशन — और schema.updated तब, जब कोई स्कीमा पब्लिश होता है; यही वह सिग्नल है जिसका नया shape पढ़ने से पहले इंतज़ार करना चाहिए। फेल हुए job में मैसेज के साथ एक typed error_code भी आता है।
AI प्रोवाइडर— provider.failed तब, जब रीट्राई के बाद किसी AI प्रोवाइडर को की गई कॉल प्रोवाइडर की ओर से फेल हो जाती है — रेट लिमिट, टाइमआउट, रिटायर्ड मॉडल, अकाउंट में क्रेडिट खत्म — और data.code बताता है कि कारण कौन-सा है; provider.threshold तब, जब किसी प्रोवाइडर key से जुड़े अकाउंट के क्रेडिट खत्म हो जाते हैं, प्रति key एक बार, जिसमें key_source बताता है कि यह आपकी अपनी key है या शेयर की गई।
डेटाबेस डेल्टा उपलब्ध— तब चलता है जब किसी Database Sync के लिए नए SQL डेल्टा तैयार हों। "Fetch Deltas on Fire" चालू होने पर नोड पेंडिंग डेल्टा लाकर लीज़ करता है और हर डेल्टा के लिए एक आइटम भेजता है, ताकि आगे Acknowledge Deltas स्टेप चल सके। कई स्कीमाओं से फ़ीड होने वाला डेटाबेस हर स्कीमा के लिए अलग नोटिफ़ाई करता है — हर एक अपना वर्कफ़्लो चलाता है — इसलिए चुनें कि यह ट्रिगर किस लिंक्ड स्कीमा को सुनेगा।

हर डिलीवरी हस्ताक्षरित होती है: X-EE-Signature हेडर में टाइमस्टैम्प किए गए बॉडी का HMAC-SHA256 होता है, और X-EE-Delivery सभी रीट्राई में एक जैसा रहता है, इसलिए आप इसे idempotency key के रूप में उपयोग कर सकते हैं। विफल डिलीवरी को आधे घंटे के दौरान तीन बार दोबारा आज़माया जाता है। आप एंडपॉइंट को हाथ से भी — बिना किसी कनेक्टर के — सेटिंग्स › वेबहुक के अंतर्गत रजिस्टर कर सकते हैं, जहाँ डिलीवरी लॉग हर प्रयास दिखाता है और आपको किसी एक को रीप्ले करने देता है।

  1. 1वे इवेंट्स जिन्हें यह एंडपॉइंट सब्सक्राइब करता है
  2. 2X-EE-Signature के पीछे मौजूद की
  3. 3हर प्रयास के लिए एक पंक्ति, स्टेटस और लेटेंसी के साथ
पंक्ति पहले POST से भी पहले लिख दी जाती है, इसलिए लॉग एक ऑडिट ट्रेल बना रहता है, भले ही आपके consumer तक कभी कुछ न पहुँचे — और जो endpoint लगातार दस डिलीवरी में विफल होता है, उसे ऐसे URL पर कतार लगाने के बजाय बंद कर दिया जाता है जिसे कोई सुन ही नहीं रहा।

Database Sync ऑपरेशन के साथ मिलकर, यह ट्रिगर केवल n8n से ही किसी बाहरी डेटाबेस को समन्वित रखता है — देखें Database Sync दस्तावेज़।

  1. 1वह विंडो जिस पर ट्रिगर नज़र रखता है
  2. 2उस एनरिचमेंट पर वापस जाएँ जिससे यह डेल्टा बना
  3. 3वह स्टेटमेंट जिसे आपका डेटाबेस लागू करता है, रिविज़न-सुरक्षित
ट्रिगर जिसकी घोषणा करता है और Fetch Deltas जिसे लीज़ पर लेता है: क्रमबद्ध पंक्तियाँ, हर एक में लागू करने योग्य सटीक स्टेटमेंट और वह संवर्धन जिससे वह आई।

सिंगल एंटिटी एनरिचमेंट

सबसे सरल वर्कफ़्लो: नए डेटा पर ट्रिगर करें, एक सिंगल एंटिटी को एनरिच करें, और परिणाम को अपने गंतव्य पर भेजें। नोड स्ट्रक्चर्ड आउटपुट को आगे भेजने से पहले पूर्ण एनरिचमेंट के पूरा होने की प्रतीक्षा करता है।

उदाहरण वर्कफ़्लो — एकल एंटिटी संवर्धन:

नोड कॉन्फ़िगरेशन — एनरिच एंटिटी ऑपरेशन:

कॉन्फ़िगरेशन

डिफ़ॉल्ट Enrich Entity और Batch Enrich ऑपरेशन सिर्फ़ ज़रूरी चीज़ें दिखाते हैं: schema, फ़ाइल अपलोड, भाषाएँ और वेब सर्च। Entity Enricher अपने-आप आपके organization के सबसे अच्छे model के साथ चलता है — आपका पिन किया हुआ डिफ़ॉल्ट, या सबसे ऊँचे benchmark स्कोर वाला model — और आपके schema से enrichment strategy चुनता है। Enrich Entity Advanced और Batch Enrich Advanced ऑपरेशन नीचे दिए गए विकल्पों का पूरा सेट उपलब्ध कराते हैं।

डायनामिक ड्रॉपडाउन से एक schema चुनें, एक या अधिक models चुनें, और entity डेटा को key-value फ़ील्ड के रूप में प्रदान करें। नोड चयनित schema के आधार पर search key फ़ील्ड स्वतः भर देता है।

वैकल्पिक सेटिंग्स में शामिल हैं रणनीति (सिंगल-पास या मल्टी-एक्सपर्टीज़), बहुभाषी आउटपुट के लिए भाषाएँ, एंटिटी प्रकार सत्यापन के लिए क्लासिफिकेशन मॉडल, मल्टी-मॉडल संघर्ष समाधान के लिए आर्बिट्रेशन मॉडल, और रिस्पॉन्स स्कीमा / स्ट्रिक्ट स्ट्रक्चर्ड आउटपुट टॉगल जो सक्षम मॉडलों पर स्कीमा-अनुरूप आउटपुट लागू करते हैं।

एनरिचमेंट में सोर्स डॉक्युमेंट फीड करने के लिए, Upload Input Binary Files टॉगल करें: नोड इनपुट आइटम की बाइनरी फाइलों को एक ही रिक्वेस्ट में अटैचमेंट के रूप में अपलोड करता है (उन सभी को, या केवल उन्हें जिनके नाम Binary Fields to Upload में दिए गए हैं) और, Delete Uploaded Attachments After Enrichment (डिफ़ॉल्ट रूप से ऑन) के साथ, एनरिचमेंट पूरा होने पर उन्हें साफ कर देता है — किसी अलग Add Attachment / Delete Attachment स्टेप की आवश्यकता नहीं। वैकल्पिक रूप से, एक ही बार अपलोड किए गए डॉक्युमेंट को कई एनरिचमेंट में दोबारा उपयोग करने के लिए एक Attachment IDs फील्ड दें (पिछली Add Attachment कॉल से कॉमा-सेपरेटेड UUIDs); दोनों सोर्स को मिलाया जा सकता है। यह Batch Enrich पर भी उपलब्ध है, जहाँ फाइलें सभी इनपुट आइटम से एकत्रित की जाती हैं और जॉब की हर एंटिटी पर लागू होती हैं। यदि फाइल सोर्स और एनरिच नोड के बीच कोई Edit Fields नोड हो, तो उसका Include Other Input Fields स्विच सक्षम करें — अन्यथा यह बाइनरी डेटा हटा देता है।

बैच एनरिचमेंट

सभी इनपुट आइटम्स को एक ही batch के रूप में प्रोसेस करें। स्प्रेडशीट, डेटाबेस या API प्रतिक्रियाओं की सूचियों को enrich करने के लिए आदर्श। सभी entities प्रति-provider रेट लिमिटिंग के साथ समानांतर में प्रोसेस होती हैं।

नोड कॉन्फ़िगरेशन — बैच एनरिच ऑपरेशन:

बैच मोड कैसे काम करता है

  1. आइटम एकत्र करें — नोड पिछले नोड से सभी इनपुट आइटम एकत्र करता है (उदा., स्प्रेडशीट की पंक्तियाँ)।
  2. बैच जॉब शुरू करें — सभी एंटिटीज़ को POST /api/batch/start के माध्यम से सबमिट किया जाता है और समानांतर में प्रोसेस किया जाता है।
  3. प्रगति स्ट्रीम करें — नोड SSE स्ट्रीम का उपभोग तब तक करता है जब तक सभी एंटिटीज़ पूरी नहीं हो जातीं या टाइमआउट नहीं पहुँच जाता।
  4. आउटपुट परिणाम — प्रति एंटिटी एक आउटपुट आइटम, एनरिच किए गए संरचित डेटा के साथ, डाउनस्ट्रीम प्रोसेसिंग के लिए तैयार।

प्रमुख विशेषताएँ

सरल और उन्नत ऑपरेशन

डिफ़ॉल्ट Enrich Entity और Batch Enrich ऑपरेशन सिर्फ़ schema, फ़ाइल अपलोड, भाषाएँ और वेब सर्च दिखाते हैं — सबसे अच्छा model और strategy अपने-आप चुन लिए जाते हैं। Advanced ऑपरेशन models, fusion, strategy और structured output पर पूरा नियंत्रण देते हैं।

डायनामिक ड्रॉपडाउन

Schema, model, भाषा और रणनीति चयनकर्ता कॉन्फ़िगरेशन के समय आपके Entity Enricher इंस्टेंस से विकल्प प्राप्त करते हैं।

SSE स्ट्रीमिंग

संवर्धन ऑपरेशन SSE स्ट्रीम को रियल-टाइम में उपभोग करते हैं, अगले नोड को परिणाम लौटाने से पहले पूर्ण होने की प्रतीक्षा करते हैं।

ऑटो-कंटिन्यू

जब प्री-फ़्लाइट क्लासिफिकेशन कोई बेमेल पहचानता है, तो कनेक्टर स्वतः जारी रहता है (n8n वर्कफ़्लो नॉन-इंटरैक्टिव होते हैं)।

कॉन्फ़िगरेबल टाइमआउट

प्रति एनरिचमेंट कॉल डिफ़ॉल्ट 300-सेकंड टाइमआउट, बड़े स्कीमा या धीमे मॉडल के लिए प्रति नोड समायोज्य।

मल्टी-मॉडल समर्थन

प्रति enrichment कई models चुनें। जब 2+ models का उपयोग किया जाता है, तो परिणाम स्वतः fuse हो जाते हैं।

डिफ़ॉल्ट रूप से आउटपुट साफ़ करें

डिफ़ॉल्ट रूप से, आउटपुट में केवल enrich किए गए डेटा फ़ील्ड होते हैं। लागत, टोकन, fusion विवरण और record ID जोड़ने के लिए "Include Enrichment Metadata" को टॉगल करें।

प्रति-model आउटपुट

डाउनस्ट्रीम तुलना के लिए वैकल्पिक रूप से फ्यूज़ किए गए परिणाम के साथ-साथ अलग-अलग मॉडल परिणाम आउटपुट करें।

प्लान सीमा की जानकारी

कॉन्फ़िगर किए जाने पर मॉडल और भाषा ड्रॉपडाउन प्लान की सीमाएँ दिखाते हैं। कोटा प्रवर्तन से उत्पन्न HTTP 402 त्रुटियाँ सीमा विवरण सहित स्पष्ट, कार्रवाई-योग्य संदेशों के रूप में प्रस्तुत की जाती हैं। मेटाडेटा आउटपुट में डाउनस्ट्रीम रूटिंग के लिए मौजूदा प्लान सीमाएँ शामिल होती हैं।

इसे किसी AI Agent से इस्तेमाल करें, या किसी उदाहरण से शुरू करें

एक AI एजेंट टूल

Entity Enricher नोड को n8n के AI Agent से टूल के रूप में जोड़ा जा सकता है, जिससे एजेंट स्वयं तय करता है कि बातचीत के बीच कब किसी एंटिटी का संवर्धन करना है या स्कीमा लाना है। ट्रिगर नोड को जानबूझकर इस तरह उपलब्ध नहीं कराया गया — ट्रिगर वर्कफ़्लो शुरू करता है, वह ऐसी चीज़ नहीं जिसे कोई एजेंट कॉल करे।

छह इम्पोर्ट करने योग्य वर्कफ़्लो

पैकेज में तैयार वर्कफ़्लो फ़ाइलें आती हैं — सिंगल संवर्धन, बैच, दस्तावेज़ से संवर्धन, इमेज से सैंपल से स्कीमा, सैंपल से स्कीमा, और डेल्टा फ़ीड को PostgreSQL में खाली करना। शुरू से जोड़ने के बजाय कोई एक इम्पोर्ट करें और उसमें अपना क्रेडेंशियल लगा दें।

Workflow आइडियाज़

n8n के साथ enrichment पाइपलाइन बनाने के सामान्य पैटर्न:

CRM enrichment— नए HubSpot/Salesforce संपर्कों पर ट्रिगर करें, कंपनी डेटा के साथ एनरिच करें, CRM रिकॉर्ड अपडेट करें।
स्प्रेडशीट पाइपलाइन— Google Sheets से एंटिटीज़ पढ़ें, बैच एनरिच करें, परिणाम वापस एक नई शीट में लिखें।
Waterfall Enrichment— कंडीशनल लॉजिक के साथ कई एनरिचमेंट चरणों को जोड़ें — पहले एक तेज़ मॉडल का उपयोग करें, विफलताओं को अधिक सक्षम मॉडल से फिर से एनरिच करें।
शेड्यूल्ड रिफ्रेश— पुराने रिकॉर्ड को नवीनतम AI मॉडल के साथ फिर से एनरिचमेंट करने के लिए क्रॉन शेड्यूल पर चलाएँ।
वेबहुक-संचालित— एक webhook एंडपॉइंट एक्सपोज़ करें जो एंटिटी डेटा स्वीकार करता है, उसे संवर्धित करता है, और परिणाम सिंक्रोनस रूप से लौटाता है।

अगले चरण