Dans cet article, nous aborderons la création d'un générateur de rapports boursiers de qualité professionnelle à l'aide de Node.js, Express et de l'API OpenAI. Notre objectif sera d'écrire du code maintenable de haute qualité tout en préservant l'intégrité des messages d'invite utilisés dans les interactions de l'API OpenAI. L'application récupérera des données boursières, effectuera une analyse du sentiment et du secteur et générera un rapport d'investissement complet.
Notre objectif est de créer un point de terminaison d'API qui génère un rapport d'investissement détaillé pour un symbole boursier donné. Le rapport comprendra :
Nous récupérerons les données boursières à partir d'API externes et utiliserons l'API OpenAI pour une analyse avancée, garantissant ainsi que les messages d'invite sont conservés avec précision.
Créez un nouveau répertoire et initialisez un projet Node.js :
mkdir stock-report-generator cd stock-report-generator npm init -y
Installez les dépendances nécessaires :
npm install express axios
Mettre en place la structure du projet :
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}`);
});
Dans utils/helpers.js, nous définirons des fonctions utilitaires pour la récupération et le traitement des données.
mkdir stock-report-generator cd stock-report-generator npm init -y
Dans routes/report.js, définissez des fonctions pour récupérer les données boursières.
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;
}
}
Ajoutez le gestionnaire de route dans 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;
}
}
Assurez-vous que vos app.js et routes/report.js sont correctement configurés, puis démarrez le serveur :
/**
* 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);
}
Utilisez curl ou Postman pour envoyer une requête POST :
mkdir stock-report-generator cd stock-report-generator npm init -y
Nous avons construit un générateur de rapports de stock de haute qualité avec les capacités suivantes :
Tout au long du processus de développement, nous nous sommes concentrés sur l'écriture d'un code professionnel et maintenable et avons fourni des explications et des annotations détaillées.
Avertissement : Cette application est uniquement à des fins éducatives. Garantissez le respect de toutes les conditions de service de l'API et gérez les données sensibles de manière appropriée.
Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!
vim sauvegarder et quitter la commande
Comment entrer en mode sans échec sur un ordinateur portable
Quel est le nom de cette voix modifiée ?
Qu'est-ce que l'indice Baidu
Quelles sont les commandes de nettoyage de disque ?
Que signifie Harmonios ?
Trois méthodes d'encodage couramment utilisées
Linux redémarre la commande de la carte réseau
![[Web front-end] Démarrage rapide de Node.js](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
