시장 심리를 분석하기 위한 Node.js Twitter 봇 만들기

트윗을 스트리밍하고 필터를 적용하여 시장 심리를 분석하는 Node.js 기반 트위터 봇을 만드는 방법을 알아봅시다!

소개

Twitter는 의견, 뉴스 및 아이디어를 공유하는 인기 있는 플랫폼입니다. 또한 특히 다양한 암호화폐 및 금융 상품에 대한 시장 심리를 이해하는 데 있어 심리 분석을 수행하는 데 유용한 데이터 소스가 될 수 있습니다.

이 자습서에서는 해시태그 및 통화 기호(예: #defi 또는 $BTC) 목록을 기반으로 트윗을 스트리밍하고 필터링하는 Node.js 기반 Twitter Bot을 만드는 과정을 안내합니다. 봇은 감정 분석 API를 사용하여 트윗의 감정을 분석합니다.

전제 조건

- Twitter API 키에 액세스할 수 있는 Twitter 개발자 계정
- Node.js(>=14.x) 설치됨

단계별 가이드

1단계: 프로젝트 설정

1. 봇을 위한 새 디렉터리를 만듭니다.

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

npm init - yes

npm install axios

3단계: Twitter API 설정

1. 프로젝트 디렉토리에서 `twitter-api.js`라는 파일을 만듭니다.
   2. 다음 코드를 파일에 넣습니다.

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. 프로젝트 디렉터리에서 `market-sentiment.js`라는 파일을 만듭니다.
   2. 다음 코드를 파일에 넣습니다.

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. 프로젝트 디렉터리에서 `index.js`라는 파일을 만듭니다.
   2. 다음 코드를 파일에 넣습니다.

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. 봇을 시작합니다(bash 터미널에서 이 명령 실행).

node index.js

SideKick 팀 및 개발자와 연락을 유지하려면 소셜에 참여하세요!