DB에 기본값으로 CURRENT_TIMESTAMP()를 넣고 테이블을 만들면 값을 저장할 때마다 DB가 알아서 DB 서버의 시간을 저장한다.
이것을 이용해 DB에 매 초마다 주식 정보를 가져와 저장하도록 해보자.
app.js
var express = require('express');
var app = express();
var http = require('http');
var server = http.createServer(app).listen(80);
console.log("server is running...")
var mysql = require('mysql');
var request = require('request');
var connection = mysql.createConnection({
host: 'localhost',
port: 3308,
user:'root',
password: '1234',
database: 'javascript' // test라는 데이터베이스에 접속
});
var bodyParser = require("body-parser");
app.use(bodyParser.urlencoded({limit: '50mb', extended: false}));
app.use(bodyParser.json({limit: '50mb'}));
// 1. 라우터 없이 서버에서 긁어서 바로 DB에 저장하는 방법.
const options = {
url:'https://polling.finance.naver.com/api/realtime.nhn?query=SERVICE_ITEM:068270|SERVICE_RECENT_ITEM:068270',
method: 'GET'
}
setInterval(function () {
request.get(options, function(err,httpResponse,body){
// console.log(JSON.parse(httpResponse.body));
response = JSON.parse(httpResponse.body);
console.log("방법1: " + response["result"]["areas"][0]["datas"][0]["nv"]);
console.log("방법2: " + response.result.areas[0].datas[0].nv);
var price = response.result.areas[0].datas[0].nv;
var unixTimeStamp = response.result.time;
function timeConverter(UNIX_timestamp){
var a = new Date(UNIX_timestamp); // 보통 1000을 곱하라고 되어 있는데 이는 13자리를 맞춰주기 위해 곱하거나 떨구는거. 네이버는 기본으로 13자리를 주어 따로 처리 할 필요가 없다.
var months = ['Jan','Feb','Mar','Apr','May','Jun','Jul','Aug','Sep','Oct','Nov','Dec'];
var year = a.getFullYear();
var month = months[a.getMonth()];
var date = a.getDate();
var hour = a.getHours();
var min = a.getMinutes();
var sec = a.getSeconds();
var time = date + ' ' + month + ' ' + year + ' ' + hour + ':' + min + ':' + sec ;
return time;
}
var time = timeConverter(unixTimeStamp)
console.log(time); // timeConverter 함수 인풋 파라미터로 유닉스타임스탬프를 넣는다.
// INSERT 쿼리 보내기
connection.query(`INSERT INTO celltrion (price, navertime) VALUES('${price}','${time}');`)
});
},1000);
});
timestamp 컬럼은 DB 테이블에 default value로 CURRENT_TIMESTAMP를 넣어서 DB 서버가 직접 기록한 시간
navertime 컬럼은 네이버에서 받아온 response에 있는 unix timestamp를 직접 바꿔서 쿼리로 string 타입으로 쏴서 넣어준 시간
2. 라우터 사용
네이버 주식 정보 가져와 매 초마다 (1) DB에 저장하고, (2) mail.html에 response 보내기 (main.html에서는 DB에서 읽어와 그래프를 그리지 않고 실시간 response를 배열에 누적해서 그래프를 그린다.)
app.js
var express = require('express');
var app = express();
var http = require('http');
var server = http.createServer(app).listen(80);
console.log("server is running...")
var mysql = require('mysql');
var request = require('request');
var connection = mysql.createConnection({
host: 'localhost',
port: 3308,
user:'root',
password: '1234',
database: 'javascript' // test라는 데이터베이스에 접속
});
var bodyParser = require("body-parser");
app.use(bodyParser.urlencoded({limit: '50mb', extended: false}));
app.use(bodyParser.json({limit: '50mb'}));
// 2. 라우터 사용 : 네이버 주식 정보 가져와 매 초마다 (1) DB에 저장하고, (2) main.html에 response 보내기 (main.html에서는 DB에서 읽어와 그래프를 그리지 않고 실시간 response를 배열에 누적해서 그래프를 그린다.)
app.get('/', function (req, res) {
res.sendfile("main.html");
});
app.get('/main', function (req, res) {
res.sendfile("main.html");
});
app.get('/getNaver', function (req, res) {
// var price = getPrice();
// res.send(price);
const options = {
url:'https://polling.finance.naver.com/api/realtime.nhn?query=SERVICE_ITEM:035720|SERVICE_RECENT_ITEM:035720',
method: 'GET'
}
request.get(options, function(err,httpResponse,body){
// console.log(JSON.parse(httpResponse.body));
response = JSON.parse(httpResponse.body);
console.log("방법1: " + response["result"]["areas"][0]["datas"][0]["nv"]);
console.log("방법2: " + response.result.areas[0].datas[0].nv);
var price = response.result.areas[0].datas[0].nv;
var unixTimeStamp = response.result.time;
function timeConverter(UNIX_timestamp){
var a = new Date(UNIX_timestamp); // 보통 1000을 곱하라고 되어 있는데 이는 13자리를 맞춰주기 위해 곱하거나 떨구는거. 네이버는 기본으로 13자리를 주어 따로 처리 할 필요가 없다.
var months = ['Jan','Feb','Mar','Apr','May','Jun','Jul','Aug','Sep','Oct','Nov','Dec'];
var year = a.getFullYear();
var month = months[a.getMonth()];
var date = a.getDate();
var hour = a.getHours();
var min = a.getMinutes();
var sec = a.getSeconds();
var time = date + ' ' + month + ' ' + year + ' ' + hour + ':' + min + ':' + sec ;
return time;
}
var time = timeConverter(unixTimeStamp)
console.log(time); // timeConverter 함수 인풋 파라미터로 유닉스타임스탬프를 넣는다.
// 쿼리 보내기
connection.query(`INSERT INTO kakao (price, navertime) VALUES('${price}','${time}');`)
res.send(""+price); // 숫자만 response로 보낼 경우 23530이라는 값을 response 보내면 HTTP Response 코드로 인식해 응답코드 23530 이라고 낭게 된다. 따라서 문자로 바꿔준다. (2개 이상을 response로 보내 배열로 만들어 보내는 경우는 무관하다.)
});
});
// const options = {
// url:'https://polling.finance.naver.com/api/realtime.nhn?query=SERVICE_ITEM:068270|SERVICE_RECENT_ITEM:068270',
// method: 'GET'
// }
// 함수를 따로 뺐는데 위에 함수 호출한 곳에 return이 되지 않는다. promise 개념이 들어가야한다 함.
// function getPrice() {
// request.get(options, function(err,httpResponse,body){
// // console.log(JSON.parse(httpResponse.body));
// response = JSON.parse(httpResponse.body);
// console.log("방법1: " + response["result"]["areas"][0]["datas"][0]["nv"]);
// console.log("방법2: " + response.result.areas[0].datas[0].nv);
// var price = response.result.areas[0].datas[0].nv;
// var unixTimeStamp = response.result.time;
//
// function timeConverter(UNIX_timestamp){
// var a = new Date(UNIX_timestamp); // 보통 1000을 곱하라고 되어 있는데 이는 13자리를 맞춰주기 위해 곱하거나 떨구는거. 네이버는 기본으로 13자리를 주어 따로 처리 할 필요가 없다.
// var months = ['Jan','Feb','Mar','Apr','May','Jun','Jul','Aug','Sep','Oct','Nov','Dec'];
// var year = a.getFullYear();
// var month = months[a.getMonth()];
// var date = a.getDate();
// var hour = a.getHours();
// var min = a.getMinutes();
// var sec = a.getSeconds();
// var time = date + ' ' + month + ' ' + year + ' ' + hour + ':' + min + ':' + sec ;
// return time;
// }
// var time = timeConverter(unixTimeStamp)
// console.log(time); // timeConverter 함수 인풋 파라미터로 유닉스타임스탬프를 넣는다.
//
// // 쿼리 보내기
// connection.query(`INSERT INTO celltrion (price, navertime) VALUES('${price}','${time}');`)
// console.log("나나난나"+price);
// return price;
// });
// };
// {"resultCode":"success",
// "result":{"pollingInterval":8000,
// "areas":[
// {"datas":[{"ll":223500,"ms":"OPEN","nv":316000,"cd":"068270","eps":2514,"bps":21666.1227,"cnsEps":3770,"ov":315500,"sv":319000,"cv":3000,"nav":null,"aq":531756,"aa":169225844500,"dv":null,"keps":2236,"nm":"��Ʈ����","rf":"5","mt":"1","pcv":319000,"tyn":"N","ul":414500,"lv":314500,"hv":323000,"cr":0.94}],
// "name":"SERVICE_ITEM"},
// {"datas":[{"ll":223500,"ms":"OPEN","nv":316000,"cd":"068270","eps":2514,"bps":21666.1227,"cnsEps":3770,"ov":315500,"sv":319000,"cv":3000,"nav":null,"aq":531756,"aa":169225844500,"dv":null,"keps":2236,"nm":"��Ʈ����","rf":"5","mt":"1","pcv":319000,"tyn":"N","ul":414500,"lv":314500,"hv":323000,"cr":0.94}],
// "name":"SERVICE_RECENT_ITEM"}],
// "time":1593051026214}}
});
res.send(""+price); 에 주목하자
숫자만 response로 보낼 경우 23530이라는 값을 response 보내면 HTTP Response 코드로 인식해 응답코드 23530 이라고 낭게 된다. 따라서 문자로 바꿔준다. (2개 이상을 response로 보내 배열로 만들어 보내는 경우는 무관하다.)
main.html (http://localhost/)
<!DOCTYPE html>
<html lang="en" dir="ltr">
<head>
<meta charset="utf-8">
<title></title>
</head>
<body>
<span id="result"></span>
<br><br>
<script type="text/javascript" src="https://www.gstatic.com/charts/loader.js"></script>
<div id="chart_div"></div>
</body>
<script src="http://code.jquery.com/jquery-latest.min.js"></script>
<script>
var time=0;
var graphValue = [];
var stockPrice;
setInterval(function () {
$.ajax({
url : '/getNaver',
type : 'GET',
data : {
},
success : function(res) {
stockPrice = res; // 크롬에서 콘솔에서 stockPrice를 찍어보면 보기 좋게 나온다.
// console.log(res);
graphValue.push([time,Number(stockPrice)])
time++;
drawCurveTypes(graphValue); // 구글 차트를 그려주는 함수를 호출한다.
}
});
},1000);
google.charts.load('current', {packages: ['corechart', 'line']});
google.charts.setOnLoadCallback(drawCurveTypes);
function drawCurveTypes() {
var data = new google.visualization.DataTable();
data.addColumn('number', '시간(초)');
data.addColumn('number', '카카오');
data.addRows(graphValue);
var options = {
hAxis: {
title: '시간(초)'
},
vAxis: {
title: '가격(원)'
},
series: {
1: {curveType: 'function'}
}
};
var chart = new google.visualization.LineChart(document.getElementById('chart_div'));
chart.draw(data, options);
}
</script>
</html>
