In diesem Artikel befassen wir uns mit der Erstellung eines professionellen Aktienberichtgenerators mithilfe von Node.js, Express und der OpenAI-API. Unser Fokus wird auf dem Schreiben von qualitativ hochwertigem, wartbarem Code liegen und gleichzeitig die Integrität der Eingabeaufforderungsnachrichten wahren, die in den OpenAI-API-Interaktionen verwendet werden. Die Anwendung ruft Aktiendaten ab, führt Stimmungs- und Branchenanalysen durch und erstellt einen umfassenden Investitionsbericht.
Unser Ziel ist es, einen API-Endpunkt zu erstellen, der einen detaillierten Investitionsbericht für einen bestimmten Börsenticker generiert. Der Bericht enthält Folgendes:
Wir rufen Bestandsdaten von externen APIs ab und verwenden die OpenAI-API für erweiterte Analysen, um sicherzustellen, dass die Eingabeaufforderungen genau erhalten bleiben.
Erstellen Sie ein neues Verzeichnis und initialisieren Sie ein Node.js-Projekt:
mkdir stock-report-generator cd stock-report-generator npm init -y
Installieren Sie die erforderlichen Abhängigkeiten:
npm install express axios
Richten Sie die Projektstruktur ein:
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}`);
});
In utils/helpers.js definieren wir Hilfsfunktionen zum Abrufen und Verarbeiten von Daten.
mkdir stock-report-generator cd stock-report-generator npm init -y
Definieren Sie in „routes/report.js“ Funktionen zum Abrufen von Bestandsdaten.
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;
}
}
Fügen Sie den Routenhandler inroutes/report.js hinzu:
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;
}
}
Stellen Sie sicher, dass Ihre app.js und Routes/report.js korrekt eingerichtet sind, und starten Sie dann den Server:
/**
* 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);
}
Verwenden Sie Curl oder Postman, um eine POST-Anfrage zu senden:
mkdir stock-report-generator cd stock-report-generator npm init -y
Wir haben einen hochwertigen Aktienberichtsgenerator mit den folgenden Funktionen entwickelt:
Während des Entwicklungsprozesses haben wir uns darauf konzentriert, professionellen, wartbaren Code zu schreiben und detaillierte Erklärungen und Anmerkungen bereitzustellen.
Haftungsausschluss: Diese Anwendung dient nur zu Bildungszwecken. Stellen Sie die Einhaltung aller API-Nutzungsbedingungen sicher und gehen Sie angemessen mit sensiblen Daten um.
Das obige ist der detaillierte Inhalt vonErstellen eines hochwertigen Aktienberichtgenerators mit Node.js, Express und OpenAI API. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!
Ist die Geschwindigkeit von PHP8.0 verbessert?
Was bedeutet PS-Maske?
Einführung in die Velocity-Syntax
So stellen Sie den binauralen Modus des Bluetooth-Headsets wieder her
Wie ist die Leistung von thinkphp?
Was ist das World Wide Web?
Win11 „Mein Computer' zum Desktop-Tutorial hinzugefügt
Was ist der Unterschied zwischen Hardware-Firewall und Software-Firewall?
![[Web-Frontend] Node.js-Schnellstart](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
