이 기사에서는 Node.js, Express 및 OpenAI API를 사용하여 전문가 수준의 주식 보고서 생성기를 만드는 방법을 살펴보겠습니다. 우리는 OpenAI API 상호 작용에 사용되는 프롬프트 메시지의 무결성을 유지하면서 고품질의 유지 관리 가능한 코드를 작성하는 데 중점을 둘 것입니다. 이 애플리케이션은 주식 데이터를 가져오고, 정서 및 업계 분석을 수행하고, 종합적인 투자 보고서를 생성합니다.
우리의 목표는 특정 주식 시세 표시기에 대한 자세한 투자 보고서를 생성하는 API 엔드포인트를 구축하는 것입니다. 보고서에는 다음이 포함됩니다.
외부 API에서 주식 데이터를 가져오고 고급 분석을 위해 OpenAI API를 사용하여 프롬프트 메시지가 정확하게 보존되도록 할 것입니다.
새 디렉토리를 생성하고 Node.js 프로젝트를 초기화합니다.
mkdir stock-report-generator cd stock-report-generator npm init -y
필요한 종속성을 설치합니다.
npm install express axios
프로젝트 구조 설정:
mkdir routes utils data touch app.js routes/report.js utils/helpers.js
// app.js
const express = require('express');
const reportRouter = require('./routes/report');
const app = express();
app.use(express.json());
app.use('/api', reportRouter);
const PORT = process.env.PORT || 3000;
app.listen(PORT, () => {
console.log(`Server is running on port ${PORT}`);
});
utils/helpers.js에서 데이터 가져오기 및 처리를 위한 유틸리티 함수를 정의합니다.
mkdir stock-report-generator cd stock-report-generator npm init -y
routes/report.js에서 주식 데이터를 가져오는 함수를 정의합니다.
npm install express axios
mkdir routes utils data touch app.js routes/report.js utils/helpers.js
// app.js
const express = require('express');
const reportRouter = require('./routes/report');
const app = express();
app.use(express.json());
app.use('/api', reportRouter);
const PORT = process.env.PORT || 3000;
app.listen(PORT, () => {
console.log(`Server is running on port ${PORT}`);
});
// utils/helpers.js
const axios = require('axios');
const fs = require('fs');
const path = require('path');
const BASE_URL = 'https://your-data-api.com'; // Replace with your actual data API
/**
* Get the start and end dates for the last year.
* @returns {object} - An object containing `start` and `end` dates.
*/
function getLastYearDates() {
const now = new Date();
const end = now.toISOString().split('T')[0];
now.setFullYear(now.getFullYear() - 1);
const start = now.toISOString().split('T')[0];
return { start, end };
}
/**
* Convert an object to a string, excluding specified keys.
* @param {object} obj - The object to convert.
* @param {string[]} excludeKeys - Keys to exclude.
* @returns {string} - The resulting string.
*/
function objectToString(obj, excludeKeys = []) {
return Object.entries(obj)
.filter(([key]) => !excludeKeys.includes(key))
.map(([key, value]) => `${key}: ${value}`)
.join('\n');
}
/**
* Fetch data from a specified endpoint with given parameters.
* @param {string} endpoint - API endpoint.
* @param {object} params - Query parameters.
* @param {any} defaultValue - Default value if the request fails.
* @returns {Promise<any>} - The fetched data or default value.
*/
async function fetchData(endpoint, params = {}, defaultValue = null) {
try {
const response = await axios.get(`${BASE_URL}${endpoint}`, { params });
return response.data || defaultValue;
} catch (error) {
console.error(`Error fetching data from ${endpoint}:`, error.message);
return defaultValue;
}
}
/**
* Read data from a local JSON file.
* @param {string} fileName - Name of the JSON file.
* @returns {any} - The parsed data.
*/
function readLocalJson(fileName) {
const filePath = path.join(__dirname, '../data', fileName);
const data = fs.readFileSync(filePath, 'utf-8');
return JSON.parse(data);
}
module.exports = {
fetchData,
objectToString,
getLastYearDates,
readLocalJson,
};
// routes/report.js
const express = require('express');
const {
fetchData,
objectToString,
getLastYearDates,
readLocalJson,
} = require('../utils/helpers');
const router = express.Router();
/**
* Fetches stock data including historical prices, financials, MDA, and main business info.
* @param {string} ticker - Stock ticker symbol.
* @returns {Promise<object>} - An object containing all fetched data.
*/
async function fetchStockData(ticker) {
try {
const dates = getLastYearDates();
const [historicalData, financialData, mdaData, businessData] = await Promise.all([
fetchData('/stock_zh_a_hist', {
symbol: ticker,
period: 'weekly',
start_date: dates.start,
end_date: dates.end,
}, []),
fetchData('/stock_financial_benefit_ths', {
code: ticker,
indicator: '按年度',
}, [{}]),
fetchData('/stock_mda', { code: ticker }, []),
fetchData('/stock_main_business', { code: ticker }, []),
]);
const hist = historicalData[historicalData.length - 1];
const currentPrice = (hist ? hist['开盘'] : 'N/A') + ' CNY';
const historical = historicalData
.map((item) => objectToString(item, ['股票代码']))
.join('\n----------\n');
const zsfzJson = readLocalJson('zcfz.json');
const balanceSheet = objectToString(zsfzJson.find((item) => item['股票代码'] === ticker));
const financial = objectToString(financialData[0]);
const mda = mdaData.map(item => `${item['报告期']}\n${item['内容']}`).join('\n-----------\n');
const mainBusiness = businessData.map(item =>
`主营业务: ${item['主营业务']}\n产品名称: ${item['产品名称']}\n产品类型: ${item['产品类型']}\n经营范围: ${item['经营范围']}`
).join('\n-----------\n');
return { currentPrice, historical, balanceSheet, mda, mainBusiness, financial };
} catch (error) {
console.error('Error fetching stock data:', error.message);
throw error;
}
}
routes/report.js에 경로 핸들러를 추가합니다.
const axios = require('axios');
const OPENAI_API_KEY = 'your-openai-api-key'; // Replace with your OpenAI API key
/**
* Interacts with the OpenAI API to get completion results.
* @param {array} messages - Array of messages, including system prompts and user messages.
* @returns {Promise<string>} - The AI's response.
*/
async function analyzeWithOpenAI(messages) {
try {
const headers = {
'Authorization': `Bearer ${OPENAI_API_KEY}`,
'Content-Type': 'application/json',
};
const requestData = {
model: 'gpt-4',
temperature: 0.3,
messages: messages,
};
const response = await axios.post(
'https://api.openai.com/v1/chat/completions',
requestData,
{ headers }
);
return response.data.choices[0].message.content.trim();
} catch (error) {
console.error('Error fetching analysis from OpenAI:', error.message);
throw error;
}
}
app.js 및 Routes/report.js가 올바르게 설정되었는지 확인한 후 서버를 시작하세요.
/**
* Performs sentiment analysis on news articles using the OpenAI API.
* @param {string} ticker - Stock ticker symbol.
* @returns {Promise<string>} - Sentiment analysis summary.
*/
async function performSentimentAnalysis(ticker) {
const systemPrompt = `You are a sentiment analysis assistant. Analyze the sentiment of the given news articles for ${ticker} and provide a summary of the overall sentiment and any notable changes over time. Be measured and discerning. You are a skeptical investor.`;
const tickerNewsResponse = await fetchData('/stock_news_specific', { code: ticker }, []);
const newsText = tickerNewsResponse
.map(item => `${item['文章来源']} Date: ${item['发布时间']}\n${item['新闻内容']}`)
.join('\n----------\n');
const messages = [
{ role: 'system', content: systemPrompt },
{
role: 'user',
content: `News articles for ${ticker}:\n${newsText || 'N/A'}\n----\nProvide a summary of the overall sentiment and any notable changes over time.`,
},
];
return await analyzeWithOpenAI(messages);
}
curl 또는 Postman을 사용하여 POST 요청 보내기:
mkdir stock-report-generator cd stock-report-generator npm init -y
저희는 다음 기능을 갖춘 고품질 주식 보고서 생성기를 구축했습니다.
개발 과정 전반에 걸쳐 전문적이고 유지 관리가 가능한 코드를 작성하는 데 중점을 두고 자세한 설명과 주석을 제공했습니다.
면책조항: 이 애플리케이션은 교육 목적으로만 사용됩니다. 모든 API 서비스 약관을 준수하고 민감한 데이터를 적절하게 처리하십시오.
위 내용은 Node.js, Express 및 OpenAI API를 사용하여 고품질 주식 보고서 생성기 구축의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!
![[웹 프런트엔드] Node.js 빠른 시작](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
