Tạo bot Twitter Node.js để phân tích tâm lý thị trường

Hãy tìm hiểu cách tạo bot Twitter dựa trên Node.js để phân tích tâm lý thị trường bằng cách truyền phát các tweet và áp dụng các bộ lọc!

Giới thiệu

Twitter đã trở thành một nền tảng phổ biến để chia sẻ quan điểm, tin tức và ý tưởng. Nó cũng có thể là một nguồn dữ liệu có giá trị để thực hiện phân tích tâm lý, đặc biệt là khi hiểu tâm lý thị trường đối với các loại tiền điện tử và công cụ tài chính khác nhau.

Trong hướng dẫn này, chúng tôi sẽ hướng dẫn bạn quy trình tạo Twitter Bot dựa trên Node.js để truyền phát các tweet và lọc chúng dựa trên danh sách các thẻ bắt đầu bằng # và ký hiệu tiền tệ (ví dụ: #defi hoặc $BTC). Bot sẽ phân tích cảm xúc của các tweet bằng API phân tích cảm xúc.

điều kiện tiên quyết

- Tài khoản Nhà phát triển Twitter có quyền truy cập vào khóa API Twitter
- Đã cài đặt Node.js (>=14.x)

Hướng dẫn từng bước một

Bước 1: Thiết lập dự án của bạn

1. Tạo một thư mục mới cho bot của bạn:

mkdir twitter-market-sentiment-bot
cd twitter-market-sentiment-bot

npm init - yes

npm install axios

Bước 3: Thiết lập Twitter API

1. Trong thư mục dự án của bạn, tạo một tệp có tên `twitter-api.js`
   2. Đặt đoạn mã sau vào tệp:

const axios = require('axios');

const api_key = 'YOUR_API_KEY';
const api_secret_key = 'YOUR_SECRET_KEY';
async function getBearerToken() {
 const headers = {
 'Authorization': `Basic ${Buffer.from(`${api_key}:${api_secret_key}`).toString('base64')}`,
 'Content-Type': 'application/x-www-form-urlencoded;charset=UTF-8',
 };
const response = await axios.post('https://api.twitter.com/oauth2/token', 'grant_type=client_credentials', { headers });
 
 return response.data.access_token;
}
module.exports = {
 getBearerToken,
};

1. Trong thư mục dự án, tạo một tệp có tên `market-sentiment.js`
   2. Đặt đoạn mã sau vào tệp:

const axios = require('axios');
async function analyzeSentiment(text) {
 try {
 // Replace the below URL with a sentiment analysis API of your choice
 const sentimentApiUrl = 'https://sentim-api.sample.com/api/v2.0/';
const response = await axios.post(sentimentApiUrl, { text });
return response.data;
 } catch (error) {
 console.error(`Error analyzing sentiment: ${error}`);
 }
}
module.exports = analyzeSentiment;

1. Trong thư mục dự án, tạo một tệp có tên `index.js`
   2. Đặt đoạn mã sau vào tệp:

const { getBearerToken } = require('./twitter-api');
const analyzeSentiment = require('./market-sentiment');
const axios = require('axios');
const filters = [
 '#defi',
 '$BTC',
 // Add more filters here
];
async function processStream(stream) {
 for await (const chunk of stream) {
 try {
 const text = JSON.parse(chunk.toString()).data.text;
 const sentiment = await analyzeSentiment(text);
 console.log(`Text: ${text}\nSentiment: ${sentiment}\n\n`);
 } catch (error) {
 console.error(`Error processing stream data: ${error}`);
 }
 }
}
(async () => {
 const token = await getBearerToken();
 const url = 'https://api.twitter.com/2/tweets/search/stream';
 const headers = { 'Authorization': `Bearer ${token}` };
 // Use filtered-stream API
 const rules = filters.map(filter => ({ "value": filter }));
 await axios.post(`${url}/rules`, { "add": rules }, { headers });
  // Start processing
  const stream = await axios({ url, headers, responseType: 'stream' }); 
  processStream(stream.data); })();

2. Khởi động bot (chạy lệnh này trong thiết bị đầu cuối bash của bạn):

node index.js

Tham gia các mạng xã hội của chúng tôi để duy trì kết nối với nhóm SideKick và các nhà phát triển!