پروژه: طراحی و پیادهسازی سیستم اتوماسیون حرفهای Instagram با n8n + PostgreSQL + REST API
توضیح پروژه
ما به دنبال یک Backend/Automation Engineer حرفهای برای طراحی و پیادهسازی یک سیستم اتوماسیون پایدار، قابل توسعه و Production-Ready برای یک مجموعه فعال در حوزه فروش محتوای وایرال اینستاگرام هستیم.
این پروژه صرفاً ساخت چند Workflow ساده در n8n نیست.
هدف، ایجاد یک Automation Infrastructure قابل اتکا است که بتواند اطلاعات مشتریان، رویدادهای Instagram، کامنتها، پاسخها، سفارشها و وضعیت پردازشها را مدیریت کند و در آینده قابلیت توسعه به چندین پیج و چندین نوع Automation را داشته باشد.
پیادهسازی باید تا حد امکان بر اساس Instagram Official API / Graph API، Webhook، REST API و معماری Event-Driven انجام شود و استفاده از روشهای غیررسمی مانند Selenium، Browser Automation یا Scraping به عنوان راهحل اصلی مورد قبول نیست.
Instagram API امکان دریافت و مدیریت کامنتها، پاسخ به کامنتها، انتشار محتوا و دریافت برخی اطلاعات/Insights را فراهم میکند و باید محدودیتها و Permissionهای API از ابتدا در طراحی لحاظ شوند.
- معماری کلی سیستم
سیستم باید حداقل از اجزای زیر تشکیل شود:
- n8n به عنوان Automation/Workflow Engine
- PostgreSQL به عنوان Database اصلی
- Instagram Graph API / Instagram API
- Webhook Endpoint
- REST API
- Authentication / Authorization
- Logging & Monitoring
- Error Handling / Retry System
- Idempotency Layer
- Queue/Execution Management در صورت نیاز
- سیستم مدیریت مشتریان و دادههای Historical
- سیستم مدیریت Eventهای Instagram
معماری باید Modular و قابل توسعه باشد.
هدف این نیست که تمام منطق داخل چند Workflow بزرگ و غیرقابل نگهداری n8n قرار گیرد.
- PostgreSQL
تمام دادههای مهم سیستم باید در PostgreSQL ذخیره شوند.
طراحی Database باید شامل مواردی مانند:
- Customers
- Instagram Accounts
- Instagram Users
- Posts / Reels
- Stories
- Comments
- Comment Replies
- Messages / Conversations در صورت امکان
- Orders / Purchases
- Products / Content Packages
- Events
- Webhook Events
- Workflow Executions
- Failed Jobs
- Retry Attempts
- Automation Rules
- Templates
- Logs
- API Tokens / Credential References
- Audit Logs
باشد.
Database Schema باید به صورت اصولی طراحی شود و از:
- Primary Key
- Foreign Key
- Unique Constraint
- Indexing
- Transactions
- Appropriate Data Types
- Normalization در بخشهای لازم
- Query Optimization
استفاده شود.
برای دادههایی که حجم زیادی پیدا میکنند، Index Strategy نیز باید از ابتدا در نظر گرفته شود.
- ورود اطلاعات مشتریان قبلی
یکی از بخشهای مهم پروژه، Import کردن اطلاعات مشتریان قبلی است.
اطلاعات موجود ممکن است از منابع مختلف مانند:
- Excel
- CSV
- Database
- API
- فایلهای Export شده
- دادههای قبلی سیستم
دریافت شوند.
باید یک فرآیند Import استاندارد طراحی شود که:
- Duplicate ایجاد نکند
- اطلاعات قبلی را خراب نکند
- رکوردهای ناقص را شناسایی کند
- Validation داشته باشد
- Import قابل Resume باشد
- در صورت Error کل فرآیند از بین نرود
- نتیجه Import قابل گزارشگیری باشد
مثلاً اگر 20,000 مشتری وارد سیستم شوند و در رکورد 13,742 خطایی اتفاق بیفتد، نباید کل فرآیند از ابتدا اجرا شود.
- Instagram Integration
ارتباط با Instagram باید تا حد امکان از طریق API رسمی Meta انجام شود.
موارد مورد انتظار:
- OAuth / Authentication
- Access Token Management
- Token Validation
- Webhook Integration
- Media Retrieval
- Comment Retrieval
- Comment Reply
- Private Reply در صورت امکان و مطابق محدودیتهای API
- Post / Reel Publishing در صورت نیاز
- Story Automation در محدوده قابلیتهای رسمی API
- Mentions / Events در صورت امکان
- Basic Insights / Metrics در صورت امکان
توسعهدهنده باید با مفاهیمی مانند:
- REST API
- HTTP Methods
- GET / POST / PATCH / DELETE
- Headers
- Bearer Token
- OAuth
- Access Token
- Webhooks
- JSON
- Pagination
- Rate Limits
- HTTP Status Codes
- API Versioning
آشنایی عملی داشته باشد.
- سیستم دریافت و پردازش Comment
هر Comment جدید باید بتواند از طریق Webhook دریافت شود.
Pipeline پیشنهادی:
Instagram
↓
Webhook
↓
Validation
↓
Event Deduplication
↓
PostgreSQL
↓
Business Logic
↓
Rule Engine
↓
Response Generator
↓
Instagram API
↓
Logging
↓
Database
سیستم نباید صرفاً با Polling دائمی کار کند؛ استفاده از Webhook در جاهایی که API پشتیبانی میکند ترجیح دارد.
Webhook Event باید قبل از پردازش Validate و Persist شود.
- سیستم Auto Reply به کامنتها
سیستم باید امکان تعریف Ruleهای مختلف برای Comment داشته باشد.
مثلاً:
اگر کاربر کامنت کرد:
"قیمت"
سیستم بتواند Action مشخصی اجرا کند.
یا:
اگر Comment شامل:
- قیمت
- خرید
- لینک
- اطلاعات
- سفارش
- کد محصول
بود، Workflow مربوطه اجرا شود.
Ruleها نباید Hard-Code شده باشند.
ترجیحاً ساختاری مانند:
Trigger → Condition → Action
پیادهسازی شود.
مثلاً:
Comment Received
→ Keyword Match
→ Identify Product
→ Find Customer
→ Check Previous Interaction
→ Generate Response
→ Reply
→ Log Result
- جلوگیری از Reply تکراری
سیستم باید Idempotent باشد.
اگر یک Webhook چند بار ارسال شود یا Workflow دوباره اجرا شود:
نباید سیستم دو بار به یک Comment پاسخ بدهد.
برای این موضوع باید از مواردی مانند:
- Unique Event ID
- Unique Comment ID
- Idempotency Key
- Database Constraints
- Transact
