تحلیل خودکار بورس و هشدارهای معاملاتی با n8n

اتوماسیون تحلیل بازار سهام و هشدارها با n8n

این راهنما نحوه راه‌اندازی یک گردش کار خودکار با استفاده از n8n برای نظارت بر داده‌های بازار سهام، تحلیل احساسات با استفاده از هوش مصنوعی و توزیع هشدارها به پلتفرم‌های مختلف را شرح می‌دهد.

این گردش کار و موارد دیگر را در کاتالوگ Axeto کاوش کنید: Axeto.ai/n8n

نمای کلی گردش کار: ارسال‌کننده هوشمند هشدار معاملات

این گردش کار داده‌های بازار اپل (AAPL) را با استفاده از TwelveData API نظارت می‌کند. شاخص‌های فنی (RSI) و داده‌های قیمت را دریافت کرده، سپس این اطلاعات را برای استخراج سیگنال‌های معاملاتی ساده پردازش می‌کند. از یک مدل هوش مصنوعی (GPT-4o) برای تبدیل این سیگنال‌ها به یک به‌روزرسانی مختصر و قابل فهم برای انسان استفاده می‌شود. در نهایت، هشدارها بر اساس اولویت محاسبه‌شده مسیریابی می‌شوند: هشدارهای با اولویت بالا به تلگرام ارسال می‌شوند، در حالی که هشدارهای با اولویت متوسط و پایین به اسلک ارسال می‌شوند. این گردش کار همچنین شامل یک مکانیزم قوی مدیریت خطا است که در صورت بروز هرگونه مشکل، یک اعلان ایمیلی ارسال می‌کند.

اجزای کلیدی:

1. زمان‌بند (Scheduled Trigger): گردش کار را در فواصل منظم آغاز می‌کند.

2. جمع‌آوری داده: داده‌های بازار بلادرنگ (RSI، قیمت، حجم) را از TwelveData دریافت می‌کند.

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

4. خلاصه بازار با هوش مصنوعی: از GPT-4o برای ایجاد یک به‌روزرسانی بازار قابل فهم برای انسان استفاده می‌کند.

5. مسیریابی اولویت و هشدارها: هشدارها را به تلگرام (بالا) یا اسلک (متوسط/پایین) توزیع می‌کند.

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

---

تشریح جزئیات گردش کار

۱. زمان‌بند (شروع گردش کار)

• گره‌ها (Nodes): Schedule Trigger1
• نوع (Type): n8n-nodes-base.scheduleTrigger
• هدف: این گره به عنوان نقطه ورود عمل کرده و گردش کار را بر اساس یک برنامه زمان‌بندی تعریف‌شده آغاز می‌کند. پیکربندی نشان می‌دهد که هر دقیقه اجرا شود.
• اتصالات: فرآیندهای موازی دریافت داده را راه‌اندازی می‌کند.
• ملاحظات: اطمینان حاصل کنید که فاصله زمانی برنامه با محدودیت‌های نرخ API و تازگی مطلوب داده‌ها مطابقت دارد.

۲. جمع‌آوری داده (TwelveData API)

• گره‌ها (Nodes): Fetch RSI Indicator, Fetch Price & Volume Data, Merge API Responses
• انواع (Types): n8n-nodes-base.httpRequest, n8n-nodes-base.merge
• هدف: این گره‌ها با هم کار می‌کنند تا داده‌های ضروری بازار را برای AAPL جمع‌آوری کنند.

* Fetch RSI Indicator: با TwelveData API تماس می‌گیرد تا شاخص قدرت نسبی (RSI) را برای AAPL با استفاده از فواصل ۵ دقیقه‌ای و دوره بازنگری ۱۴ دریافت کند.

* Fetch Price & Volume Data: آخرین داده‌های قیمت، از جمله قیمت پایانی و حجم را برای AAPL دریافت می‌کند.

* Merge API Responses: داده‌های هر دو فراخوانی API را در یک جریان داده واحد برای پردازش بعدی ترکیب می‌کند.

• نمونه‌های نقطه پایانی API (API Endpoint Examples):

* RSI: https://api.twelvedata.com/rsi?symbol=AAPL&interval=5min&time_period=14&apikey=YOUR_TOKEN_HERE

* Quote: https://api.twelvedata.com/quote?symbol=AAPL&apikey=YOUR_TOKEN_HERE

• ملاحظات:

* YOUR_TOKEN_HERE را با کلید API واقعی TwelveData خود جایگزین کنید.

* خطاهای احتمالی API را مدیریت کنید (به عنوان مثال، کلیدهای نامعتبر، محدودیت‌های نرخ، تعطیلی بازار).

* اطمینان حاصل کنید که انواع داده‌ها به درستی مدیریت می‌شوند، به خصوص هنگام تبدیل مقادیر رشته‌ای به اعداد.

۳. پردازش سیگنال (منطق سفارشی)

• گره (Node): Calculate Trading Signals
• نوع (Type): n8n-nodes-base.code
• هدف: این گره کد سفارشی جاوا اسکریپت، داده‌های بازار ادغام‌شده را برای تولید سیگنال‌های معاملاتی عملی تحلیل می‌کند. این گره موارد زیر را تعیین می‌کند:

* طبقه‌بندی مومنتوم (Momentum Classification): مومنتوم سهام را بر اساس مقادیر RSI دسته‌بندی می‌کند (به عنوان مثال، OVERBOUGHT, NEUTRAL, OVERSOLD).

* سیگنال حجم (Volume Signal): تشخیص می‌دهد که آیا حجم معاملات فعلی به طور قابل توجهی بالاتر از میانگین است (HIGH_VOLUME).

* اقدام (Action): یک اقدام معاملاتی بالقوه (PREPARE_BUY, WATCH, WAIT) را بر اساس سیگنال‌های مومنتوم و حجم پیشنهاد می‌دهد.

• خروجی: یک آیتم داده واحد حاوی symbol, price, rsi, momentum, volumeSignal, و action.
• ملاحظات:

* کد به نام‌های فیلد خاصی از گره‌های بالادستی متکی است. اطمینان حاصل کنید که این موارد سازگار باقی می‌مانند.

* موارد عدم وجود یا نامعتبر بودن داده‌های RSI یا قیمت (null, NaN) را مدیریت کنید.

۴. خلاصه بازار با هوش مصنوعی (ادغام LLM)

• گره‌ها (Nodes): OpenAI GPT-4 Model, Generate AI Summary
• انواع (Types): @n8n/n8n-nodes-langchain.lmChatOpenAi, @n8n/n8n-nodes-langchain.agent
• هدف: این بخش از Azure OpenAI (از طریق گره‌های LangChain) برای تبدیل سیگنال‌های معاملاتی ساختاریافته به یک خلاصه بازار مختصر و قابل فهم برای انسان که برای پلتفرم‌هایی مانند اسلک مناسب است، استفاده می‌کند.

* OpenAI GPT-4 Model: اتصال به سرویس Azure OpenAI را پیکربندی می‌کند و مدل gpt-4o را مشخص می‌کند.

* Generate AI Summary: به عنوان یک عامل عمل می‌کند که به مدل هوش مصنوعی دستور می‌دهد. این گره دستور داده شده است تا یک به‌روزرسانی "آماده برای اسلک" شامل یک عنوان، موارد گلوله‌ای و یک خط اقدام پررنگ ایجاد کند، در حالی که به شدت از ارائه مشاوره مالی خودداری می‌کند.

• دستورالعمل‌های کلیدی پرامپت (Key Prompt Instructions):

* قالب برای اسلک: عنوان کوتاه، موارد گلوله‌ای (•)، خط اقدام پررنگ.

* پیام سیستم: لحن حرفه‌ای، مختصر، خنثی؛ بدون مشاوره مالی.

• ملاحظات:

* اطمینان حاصل کنید که بسته گره‌های LangChain در نمونه n8n شما نصب شده است.

* اعتبارنامه Azure OpenAI خود را به درستی در گره OpenAI GPT-4 Model پیکربندی کنید.

* به محدودیت‌های احتمالی مدل هوش مصنوعی، مانند محدودیت‌های توکن یا نادرستی‌های گاه به گاه، به خصوص اگر داده‌های ورودی ناقص باشند، توجه داشته باشید.

۵. مسیریابی اولویت و اعلان‌ها

• گره‌ها (Nodes): Assign Alert Priority, Route by Priority, Send to Telegram (High Priority), Send to Slack (Low Priority)
• انواع (Types): n8n-nodes-base.code, n8n-nodes-base.if, n8n-nodes-base.telegram, n8n-nodes-base.slack
• هدف: این مرحله فوریت هشدار را تعیین کرده و آن را به کانال اعلان مناسب ارسال می‌کند.

* Assign Alert Priority: یک گره کد که سطح اولویت (HIGH, MEDIUM, LOW) را بر اساس شرایط RSI و سیگنال حجم اختصاص می‌دهد.

* Route by Priority: یک گره IF که اولویت اختصاص‌یافته را بررسی می‌کند.

* اگر HIGH باشد، گردش کار به Send to Telegram ادامه می‌دهد.

* اگر HIGH نباشد (یعنی MEDIUM یا LOW)، به Send to Slack ادامه می‌دهد.

* Send to Telegram (High Priority): هشدارهای حیاتی را به یک چت تلگرام مشخص ارسال می‌کند. پیام شامل نشانگرهای فوریت (🚨) و خلاصه تولید شده توسط هوش مصنوعی است.

* Send to Slack (Low Priority): به‌روزرسانی‌های کمتر فوری را به یک کانال اسلک تعیین‌شده ارسال می‌کند.

• پیکربندی:

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

* اطمینان حاصل کنید که توکن ربات تلگرام و اعتبارنامه‌های API اسلک/محدوده‌های OAuth به درستی پیکربندی شده‌اند.

• ملاحظات:

* منطق اولویت حیاتی است؛ آن را مرور کنید تا اطمینان حاصل کنید که نیازهای هشدار شما را به دقت منعکس می‌کند.

* تأیید کنید که ربات/کاربر مجوزهای لازم را در هر دو تلگرام و اسلک دارد.

۶. مدیریت خطای سراسری

• گره‌ها (Nodes): Workflow Error Handler, Send a message1
• انواع (Types): n8n-nodes-base.errorTrigger, n8n-nodes-base.gmail
• هدف: این شبکه ایمنی تضمین می‌کند که در صورت بروز خطای مدیریت نشده در هر بخشی از گردش کار، به شما اطلاع داده شود.

* Workflow Error Handler: این گره به طور خودکار زمانی فعال می‌شود که هر گره قبلی با شکست مواجه شود و خطا به صورت محلی مدیریت نشود.

* Send a message1: به عنوان یک گره Gmail پیکربندی شده است، یک اعلان ایمیلی حاوی جزئیات خطا، از جمله نام گره، پیام خطا و یک مُهر زمانی ارسال می‌کند.

• پیکربندی:

* آدرس ایمیل گیرنده را تنظیم کنید (user@example.com یک جایگزین است).

* اعتبارنامه حساب Gmail خود را پیکربندی کنید (استفاده از OAuth2 توصیه می‌شود).

• ملاحظات:

این پردازنده خطاهای مدیریت نشده* را دریافت می‌کند. گره‌هایی که برای "ادامه در صورت شکست" (Continue on Fail) پیکربندی شده‌اند، ممکن است این اعلان را راه‌اندازی نکنند.

* اطمینان حاصل کنید که موضوع و بدنه ایمیل به وضوح گردش کار و ماهیت خطا را مشخص می‌کنند.