پردازش هوشمند سرنخ با Apify، Gemini و Google Sheets

پردازش سرنخ با قدرت هوش مصنوعی با استفاده از Apify، Gemini و Google Sheets

این گردش کار، پردازش سرنخ‌های جمع‌آوری شده از طریق APIهای Apify/Apollo را خودکار می‌کند. از هوش مصنوعی Google Gemini برای اعتبارسنجی و غنی‌سازی استفاده می‌کند، سپس نتایج را در Google Sheets ذخیره می‌کند. این گردش کار برای پردازش دسته‌ای حجم بالای سرنخ‌ها (تا ۱۰۰۰ مورد در هر دسته) طراحی شده است و از طریق اعتبارسنجی، حذف موارد تکراری و قالب‌بندی مبتنی بر هوش مصنوعی، کیفیت داده‌ها را تضمین می‌کند. یک گزارش خلاصه پس از اتمام از طریق تلگرام ارسال می‌شود.

گردش کارهای بیشتر n8n را در Axeto.ai کاوش کنید: https://axeto.ai/n8n

موارد استفاده

• اعتبارسنجی خودکار سرنخ‌ها: کسب‌وکارها و تیم‌های فروش که سرنخ‌ها را از پلتفرم‌هایی مانند Apollo یا Apify جمع‌آوری می‌کنند، می‌توانند این داده‌ها را به‌طور خودکار اعتبارسنجی و غنی‌سازی کنند.
• پاک‌سازی و یکپارچه‌سازی داده‌ها: فرآیندهای نیازمند پاک‌سازی داده‌ها با قدرت هوش مصنوعی، تولید شناسه منحصربه‌فرد و حذف موارد تکراری را قبل از یکپارچه‌سازی با CRM یا ابزارهای فروش، ساده‌سازی کنید.
• پردازش دسته‌ای با اعلان‌ها: حجم زیادی از سرنخ‌ها را با محدودیت نرخ داخلی به‌طور مؤثر پردازش کنید و گزارش‌های خلاصه را از طریق تلگرام دریافت نمایید.

ساختار گردش کار

این گردش کار به صورت منطقی به بلوک‌های زیر تقسیم می‌شود:

1. راه‌اندازی و دریافت ورودی: گردش کار را آغاز کرده و داده‌های خام سرنخ را دریافت می‌کند.

2. کسب داده‌های سرنخ: داده‌های سرنخ جمع‌آوری شده را از API Apify/Apollo دریافت می‌کند.

3. تقسیم به دسته‌ها و حلقه‌زنی: مجموعه‌های بزرگ سرنخ را به دسته‌های قابل مدیریت تقسیم کرده و تاخیری بین پردازش هر دسته اعمال می‌کند.

4. پردازش و اعتبارسنجی هوش مصنوعی: از هوش مصنوعی Google Gemini با ادغام Langchain برای اعتبارسنجی، پاکسازی، تولید شناسه‌های منحصربه‌فرد، حذف موارد تکراری و قالب‌بندی داده‌های سرنخ استفاده می‌کند.

5. یکپارچه‌سازی Google Sheets: داده‌های موجود را از Google Sheets برای حذف موارد تکراری می‌خواند و سرنخ‌های پردازش شده جدید را اضافه می‌کند.

6. گزارش‌دهی تلگرام: یک گزارش خلاصه از پردازش دسته‌ای را به یک چت تلگرام ارسال می‌کند.

---

تحلیل گره‌های دقیق

۱. دریافت تریگر و ورودی

این بلوک به عنوان نقطه ورود گردش کار عمل می‌کند و داده‌ها را از یک تریگر خارجی دریافت می‌کند.

• گره: When Executed by Another Workflow

* نوع: executeWorkflowTrigger

* عملکرد: گردش کار را هنگام فراخوانی توسط یک گردش کار دیگر n8n آغاز می‌کند. هرگونه داده ورودی دریافتی را منتقل می‌کند.

* پیکربندی: منبع ورودی برای انتقال داده‌ها روی "Passthrough" تنظیم شده است.

* ورودی: به صورت خارجی تریگر می‌شود.

* خروجی: داده‌ها را به گره APIFY Post Request ارسال می‌کند.

* موارد مرزی: گردش کار تریگر نشده؛ داده ورودی ارائه نشده است.

• گره: Sticky Note (مستندات)

* نوع: stickyNote

* عملکرد: مستنداتی را برای این بلوک ارائه می‌دهد.

۲. کسب داده‌های سرنخ

این بلوک داده‌های سرنخ جمع‌آوری شده را از API Apify/Apollo بازیابی می‌کند.

• گره: APIFY Post Request

* نوع: httpRequest

* عملکرد: با ارسال یک درخواست POST به نقطه پایانی API Apify/Apollo، یک کار جمع‌آوری را آغاز می‌کند.

* پیکربندی: نیاز به پیکربندی متد POST، URL API و هدرهای احراز هویت به صورت خارجی دارد.

* ورودی: داده‌ها را از گره When Executed by Another Workflow دریافت می‌کند.

* خروجی: داده‌ها را به گره Wait for APIFY to Scrape ارسال می‌کند.

* موارد مرزی: خرابی احراز هویت API، نقطه پایانی نامعتبر، مهلت زمانی شبکه، پاسخ‌های API نامعتبر.

• گره: Wait for APIFY to Scrape

* نوع: wait

* عملکرد: گردش کار را برای مدت زمان مشخصی (مثلاً ۳۰ ثانیه) متوقف می‌کند تا کار جمع‌آوری تکمیل شود.

* پیکربندی: زمان انتظار ثابت ۳۰ ثانیه.

* ورودی: داده‌ها را از APIFY Post Request دریافت می‌کند.

* خروجی: داده‌ها را به گره Apify Get Request ارسال می‌کند.

* موارد مرزی: زمان انتظار ناکافی منجر به داده‌های ناقص؛ زمان انتظار بیش از حد باعث تاخیر در پردازش می‌شود.

• گره: Apify Get Request

* نوع: httpRequest

* عملکرد: با استفاده از یک درخواست GET، API Apify را برای بازیابی نتایج کار جمع‌آوری، نظرسنجی می‌کند.

* پیکربندی: از شناسه کار جمع‌آوری به دست آمده از گره قبلی استفاده می‌کند.

* ورودی: داده‌ها را پس از دوره انتظار دریافت می‌کند.

* خروجی: داده‌ها را به گره Loop Over Items ارسال می‌کند.

* موارد مرزی: مهلت زمانی API، هنوز داده‌ای در دسترس نیست، داده‌های نامعتبر دریافت شده است.

• گره: Sticky Note (اطلاعات فراخوانی API)

* نوع: stickyNote

* عملکرد: راه‌اندازی و پارامترهای فراخوانی API را توضیح می‌دهد.

۳. تقسیم دسته‌ای و حلقه‌زنی

این بلوک تقسیم سرنخ‌ها به دسته‌های کوچکتر و مدیریت حلقه پردازش را بر عهده دارد.

• گره: Loop Over Items

* نوع: splitInBatches

* عملکرد: آرایه سرنخ‌های جمع‌آوری شده را به دسته‌هایی با حداکثر ۱۰۰۰ مورد در هر دسته تقسیم می‌کند.

* پیکربندی: batchSize روی ۱۰۰۰ تنظیم شده است. reset روی false تنظیم شده است تا تداوم دسته حفظ شود.

* ورودی: آرایه داده‌های سرنخ را از Apify Get Request دریافت می‌کند.

* خروجی:

* خروجی ۱: دسته فعلی را به بلوک پردازش هوش مصنوعی ارسال می‌کند.

* خروجی ۲: به گره Wait for APIFY to Scrape (یا یک گره انتظار مشابه) بازمی‌گردد تا قبل از پردازش دسته بعدی، تاخیری ایجاد کند.

* موارد مرزی: آرایه ورودی خالی یا کوچکتر از اندازه دسته؛ دسته‌هایی حاوی کمتر از ۱۰۰۰ سرنخ.

• گره: Sticky Note (توضیح پردازش دسته)

* نوع: stickyNote

* عملکرد: منطق پردازش دسته را توصیف می‌کند.

• گره: Sticky Note (محدودیت نرخ)

* نوع: stickyNote

* عملکرد: تاخیر ۳۰ ثانیه‌ای اعمال شده بین دسته‌ها برای جلوگیری از محدودیت نرخ API را توضیح می‌دهد.

۴. پردازش و اعتبارسنجی هوش مصنوعی

این هسته اصلی گردش کار است که در آن داده‌های سرنخ با استفاده از هوش مصنوعی Google Gemini پردازش و اعتبارسنجی می‌شوند.

• گره: Knowledge Base Agent

* نوع: @n8n/n8n-nodes-langchain.agent

* عملکرد: پردازش هوش مصنوعی را هماهنگ می‌کند. داده‌های سرنخ (نام، ایمیل، نام شرکت) را اعتبارسنجی می‌کند، شماره تلفن‌ها و مکان‌ها را قالب‌بندی می‌کند، شناسه‌های منحصر به فرد سرنخ (فرمت: AP-DDMMYY-xxxx) تولید می‌کند و با بررسی داده‌های موجود Google Sheets، حذف موارد تکراری را بر اساس آدرس‌های ایمیل انجام می‌دهد. همچنین یک پیام خلاصه برای تلگرام تولید می‌کند.

* پیکربندی: از یک پرامپت سفارشی استفاده می‌کند که هوش مصنوعی را در مورد اعتبارسنجی دقیق، قالب‌بندی و تولید خلاصه راهنمایی می‌کند.

* ورودی: دسته‌ای از سرنخ‌ها را از Loop Over Items و داده‌های سرنخ موجود را از گره Get row(s) in sheet دریافت می‌کند.

* خروجی: داده‌های قالب‌بندی شده را برای Google Sheets و متن پیام خلاصه را به بلوک گزارش تلگرام ارسال می‌کند.

* موارد مرزی: فیلدهای حیاتی گم شده (سرنخ‌ها نادیده گرفته می‌شوند)؛ فیلدهای اختیاری گم شده (پرچم‌گذاری می‌شوند)؛ خرابی یا مهلت زمانی پاسخ هوش مصنوعی.

* حافظه هوش مصنوعی: از یک بافر حافظه برای زمینه استفاده می‌کند.

• گره: Google Gemini Chat Model

* نوع: @n8n/n8n-nodes-langchain.lmChatGoogleGemini

* عملکرد: قابلیت‌های پردازش زبان طبیعی را برای Knowledge Base Agent فراهم می‌کند.

* پیکربندی: تنظیمات پیش‌فرض، متصل به گره عامل.

* موارد مرزی: محدودیت‌های سهمیه API، خطاهای احراز هویت.

• گره: Simple Memory

* نوع: @n8n/n8n-nodes-langchain.memoryBufferWindow

* عملکرد: زمینه مکالمه را برای حفظ تداوم عامل هوش مصنوعی ذخیره می‌کند.

* پیکربندی: از یک پنجره ۲۰ پیامی استفاده می‌شود. کلید جلسه را می‌توان به صورت پویا تنظیم کرد.

* موارد مرزی: سرریز یا بازنشانی حافظه.

• گره: Get row(s) in sheet

* نوع: n8n-nodes-base.googleSheetsTool (عملیات خواندن)

* عملکرد: سرنخ‌های موجود را از یک Google Sheet مشخص می‌خواند تا حذف موارد تکراری مبتنی بر ایمیل را امکان‌پذیر کند.

* پیکربندی: برای خواندن از یک برگه/تب خاص (مثلاً "Raw Scraping") در یک سند Google Sheet مشخص پیکربندی شده است.

* ورودی: داده‌ها را از گره Loop Over Items دریافت می‌کند.

* خروجی: داده‌های برگه موجود را برای بررسی حذف موارد تکراری به Knowledge Base Agent ارسال می‌کند.

* موارد مرزی: خطاهای دسترسی به برگه، برگه خالی، محدودیت نرخ API Google Sheets.

• گره: Append row in sheet

* نوع: n8n-nodes-base.googleSheetsTool (عملیات افزودن)

* عملکرد: داده‌های سرنخ اعتبارسنجی و پردازش شده را ردیف به ردیف در Google Sheet می‌نویسد.

* پیکربندی: فیلدهای خروجی از پردازش هوش مصنوعی (مانند شناسه سرنخ، نام، ایمیل، تلفن، شرکت) را به ستون‌های مربوطه در Google Sheet نگاشت می‌کند.

* ورودی: داده‌های سرنخ پردازش شده را از Knowledge Base Agent دریافت می‌کند.

* خروجی: داده‌ها را به Google Sheet اضافه می‌کند.

* موارد مرزی: خطاهای نوشتن در برگه، محدودیت سهمیه API Google Sheets.

• گره: Sticky Note (توضیح موتور هوش مصنوعی)

* نوع: stickyNote

* عملکرد: توضیحات دقیقی در مورد منطق پردازش هوش مصنوعی ارائه می‌دهد.

• گره: Sticky Note (جزئیات ادغام Google Sheets)

* نوع: stickyNote

* عملکرد: جزئیات ادغام با Google Sheets را توضیح می‌دهد.

۵. گزارش‌دهی تلگرام

این بلوک خلاصه‌ای از نتایج پردازش دسته را به یک چت تلگرام ارسال می‌کند.

• گره: Send a text message

* نوع: telegram

* عملکرد: یک پیام تجمیعی به یک چت تلگرام ارسال می‌کند که پردازش دسته فعلی را خلاصه می‌کند. پیام شامل تعداد سرنخ‌های پردازش شده، با موفقیت اضافه شده، پرچم‌گذاری شده و نادیده گرفته شده است.

* پیکربندی: متن پیام از خروجی Knowledge Base Agent دریافت می‌شود. شناسه چت را می‌توان به صورت پویا تنظیم کرد، اغلب از داده‌های ورودی تریگر تلگرام.

* ورودی: متن خلاصه را از Knowledge Base Agent دریافت می‌کند.

* خروجی: پیام خلاصه را به تلگرام ارسال می‌کند.

* موارد مرزی: خطاهای API تلگرام، شناسه چت نامعتبر، مشکلات قالب‌بندی پیام.

• گره: Sticky Note (جزئیات گزارش‌دهی تلگرام)

* نوع: stickyNote

* عملکرد: محتوا و قالب‌بندی پیام خلاصه تلگرام را توصیف می‌کند.

---

جدول خلاصه