03 씨스톡 국내주식정보 가져오기 파이썬 pykrx 모듈사용

https://www.moayo.net/p-moayo-21025 (짧은주소)

1) 국내 주식 정보 얻어오기 파이썬작업 (개인 PC)

in_stock.py pykrx 모듈사용 (국내 주식정보 제공 모듈) 2) 데이터 입력하는 부분

3) in_stock.py 실행을 윈도우 스케줄에 추가

in_stock.py (파이썬파일)

#처음에 오류는 나오지 않는데 아무것도 나오지 않아 무엇이 문제인가 했는데 pip install matplotlib 설치한이후에 정상작동됨
from pykrx import stock
import pandas as pd #데이터를 실수형으로 받기위해
import requests
from bs4 import BeautifulSoup
import json
import time
from datetime import datetime #today 얻기위해
import sys

today=datetime.today()
wdate=today.strftime('%Y%m%d')#오늘

sdate=str(wdate) #오늘 날짜로 시작
edate=str(wdate) #오늘 날짜로 종료

stock_code = stock.get_market_ticker_list(market="KOSPI")#코스피 목록
for i in range(len(stock_code)) :    
    try:    
        df = stock.get_market_ohlcv_by_date(sdate, edate, stock_code[i]) #개별좀옥 가져오는 부분
        stock_name = stock.get_market_ticker_name(stock_code[i])#종목명
        dates = df.index.tolist()
        s_prices = df["시가"].tolist()
        h_prices = df["고가"].tolist()
        l_prices = df["저가"].tolist()
        e_prices = df["종가"].tolist()
        c_prices = df["거래량"].tolist()
        t_prices = df["거래대금"].tolist()
        p_prices = df["등락률"].tolist()

        #데이터 가공하기
        data = {
        "market_code":"KOSDAQ"
        ,"stock_code":stock_code[i]
        ,"stock_name":stock_name
        ,"date": df.index.strftime("%Y-%m-%d").tolist()
        ,"s_prices": s_prices
        ,"h_prices": h_prices
        ,"l_prices": l_prices
        ,"e_prices": e_prices
        ,"c_prices": c_prices
        ,"t_prices": t_prices
        ,"p_prices": p_prices
        }

        data=json.dumps(data)
        #print(data)

        #데이터를 처리하기 위해 전송하는 부분
        obj={"json_text":data}#전송할 obj값만들기
        res=requests.post("http://cstock.co.kr/plugins/in_stock.php",data=obj) #하나씩 데이터를 전송함

        j=i+1 #하나씩 증가시킴
        print("KOSPI Result : "+str(j))
    except:
        print("KOSPI Error : "+stock_code[i])



stock_code = stock.get_market_ticker_list(market="KOSDAQ")#코스닥 목록
for i in range(len(stock_code)) :
    try:    
        df = stock.get_market_ohlcv_by_date(sdate, edate, stock_code[i]) #개별좀옥 가져오는 부분
        stock_name = stock.get_market_ticker_name(stock_code[i])#종목명
        dates = df.index.tolist()
        s_prices = df["시가"].tolist()
        h_prices = df["고가"].tolist()
        l_prices = df["저가"].tolist()
        e_prices = df["종가"].tolist()
        c_prices = df["거래량"].tolist()
        t_prices = df["거래대금"].tolist()
        p_prices = df["등락률"].tolist()

        #데이터 가공하기
        data = {
        "market_code":"KOSDAQ"
        ,"stock_code":stock_code[i]
        ,"stock_name":stock_name
        ,"date": df.index.strftime("%Y-%m-%d").tolist()
        ,"s_prices": s_prices
        ,"h_prices": h_prices
        ,"l_prices": l_prices
        ,"e_prices": e_prices
        ,"c_prices": c_prices
        ,"t_prices": t_prices
        ,"p_prices": p_prices
        }
        data=json.dumps(data)
        #print(data)
       
        #데이터를 처리하기 위해 전송하는 부분
        obj={"json_text":data}#전송할 obj값만들기
        res=requests.post("http://cstock.co.kr/plugins/in_stock.php",data=obj) #하나씩 데이터를 전송함

        print("KOSDAQ Result : "+str(j+i+1))#코스피 실행갯수 합산후출력
    except:
        print("KOSDAQ Error : "+stock_code[i])

in_stock.php (php 데이터입력)

<?include"{$_SERVER[DOCUMENT_ROOT]}default/header.php"?>
<?
if(!$json_text){//값이 없으면 멈춤
  //exit;
}

// JSON 데이터 파싱
$json_text=stripslashes($json_text);//종목명에 J\ub124\ud2b8\uc6cd\uc2a4 식이여서 입력되지 않는 오류때문에 추가함
$data=json_decode($json_text,true);//배열형태로 변경
$len=count($data[date]);

$market_code=$data["market_code"];//마켓코드
$stock_code=$data["stock_code"];//종목코드
$stock_name=$data["stock_name"];//종목명


//종목이 없는경우 추가 해야하는 부분
{
  $ccsql="  select idx_code,c_posi from {$table[stock]}_cat where 1 ";
  $ccsql.=" and value='$stock_code'";
  $ccsql.=" and ext2='$market_code'";
  $ccresult=mysql_query($ccsql,$dbcon);
  $ccrow=mysql_fetch_array($ccresult);
  if(!$ccrow[idx_code]){//입력하기
    $isql="  insert {$table[stock]}_cat set ";
    $isql.="  use_yn='y'";
    $isql.=" ,dep_code='1000'";
    $isql.=" ,level='1'";
    $isql.=" ,title='$stock_name'";//종목명
    $isql.=" ,value='$stock_code'";//종목코드
    $isql.=" ,ext2='$market_code'";//시장코드
    echo $isql;
    mysql_query($isql,$dbcon);//큰카테고리 입력
    $idx=mysql_insert_id($dbcon);
    $key_code=$idx;

    //포지션 업데이트
    $usql="update {$table[stock]}_cat set ord_code='$idx', c_posi='$ccrow[c_posi]@$idx' where idx_code='$idx'";
    mysql_query($usql,$dbcon);
  }
}

for($i=0;$i<$len;$i++){
  $wdate=$data["date"][$i];//날짜
  $p_int1=str_replace(array("",","),"",$data["s_prices"][$i]);//시가
  $p_int2=str_replace(array("",","),"",$data["h_prices"][$i]);//고가
  $p_int3=str_replace(array("",","),"",$data["l_prices"][$i]);//저가
  $p_int4=str_replace(array("",","),"",$data["e_prices"][$i]);//종가
  $p_int5=str_replace(array("",","),"",$data["c_prices"][$i]);//거래량
  $p_int6=str_replace(array("",","),"",$data["t_prices"][$i]);//거래대금
  $p_int7=str_replace(array("",","),"",$data["p_prices"][$i]);//등락률

/*
  //입력하기전에 해당 내용이 있는지 점검
  $csql="  select * from {$table[stock]} where 1";
  $csql.=" and p_title='$stock_code'";
  $csql.=" and ext1='$market_code'";//시장코드
  $csql.=" and wdate='".date("Y-m-d 23:59:59",strtotime($wdate))."'";//날짜
  $cresult=mysql_query($csql,$dbcon);
  $crow=mysql_fetch_array($cresult);
*/
  //if($crow[idx_code]){//내용이 있는경우 수정
  if(false){
    $usql="  update {$table[stock]} set ";
    $usql.="  udate=now()";//날짜
    $usql.=" ,p_int1='$p_int1'";//시가
    $usql.=" ,p_int2='$p_int2'";//고가
    $usql.=" ,p_int3='$p_int3'";//저가
    $usql.=" ,p_int4='$p_int4'";//종가(현재가)
    $usql.=" ,p_int5='$p_int5'";//거래량
    $usql.=" ,p_int6='$p_int6'";//거래대금
    $usql.=" ,p_int7='$p_int7'";//등락률
    $usql.=" where 1 ";
    $usql.=" and p_title='$stock_code'";
    $usql.=" and ext1='$market_code'";//시장코드
    $usql.=" and wdate='".date("Y-m-d 23:59:59",strtotime($wdate))."'";//날짜
    mysql_query($usql,$dbcon);

    $log_list.="$usql\n";//로그기록
  }else{//없는경우 입력
    $isql="  insert {$table[stock]} set ";
    $isql.="  p_content='$stock_code'";
    $isql.=" ,p_title='$stock_code'";
    $isql.=" ,wdate='".date("Y-m-d 23:59:59",strtotime($wdate))."'";//날짜
    $isql.=" ,udate=now()";//날짜
    $isql.=" ,ext1='$market_code'";//시장코드
    $isql.=" ,ext2='".$stock_code.$wdate."'";//날짜
    $isql.=" ,p_int1='$p_int1'";//시가
    $isql.=" ,p_int2='$p_int2'";//고가
    $isql.=" ,p_int3='$p_int3'";//저가
    $isql.=" ,p_int4='$p_int4'";//종가(현재가)
    $isql.=" ,p_int5='$p_int5'";//거래량
    $isql.=" ,p_int6='$p_int6'";//거래대금
    $isql.=" ,p_int7='$p_int7'";//등락률
    mysql_query($isql,$dbcon);

    $log_list.="$isql\n";//로그기록
  }
}


exit;

//log 기록하는 부분
//log_save($log_list);

?>

유사한정보