키움 API 선물,옵션 가격, 미결제약정 분봉데이터 수집하기
선물, 옵션 분봉차트 기준 거래정보와 미결제약정 정보를 추가로 수집하는 모듈을 추가 절차 요약
추가대상 TRCODE : OPT50029, OPT50062, OPT50064, OPT50067
| trcode = "OPT50029" : 선물분차트 (종목코드, 시간단위) --과거이력포함 trcode = "OPT50062" : 선물미결제약정분차트요청 (종목코드, 시간단위) --과거이력포함 trcode = "OPT50067" : 옵션분차트요청 ( 종목코드, 시간단위) --과거이력포함 trcode = "OPT50064" : 옵션미결제약정분차트요청 (종목코드, 시간단위) --과거이력포함 |
프로그램 수정 및 신규작성 (파이썬 기준)
1. 메인 호출용 프로그램 작성 - KW_000_min30_main.py
- 키움의 시간당 트랜젝션 제약을 해결하기 위하여 실제 프로그램을 반복호출하는 용도
2. 메인수행 프로그램 작성 - KW_000_min30_option.py
- 데이터 수집을 위한 메인로직으로 필요한 모듈을 호출하는 프로그램
#####전체로직 포함하는 메인 함수
# print (" KW_WeekProc 시작 ===>")
rqname, scrno, input_list = Comm_Func.Get_Input_List(trcode, code_option, gb_min) ##키움 TR코드에 따른 입력변수 정의
kiwoom.set_input_value(input_list) ## ## 키움 TR코드에 따른 입력변수에 값 정의
kiwoom.comm_rq_data(rqname, trcode, 0, scrno) ### TR의 데이터 요청 : 실행후 _receive_tr_data()이 자동 호출됨(event)
G_sqldata = kiwoom.G_sqldata ## TR결과를 작업변수로 할당
if len(G_sqldata) > 0 :
DB_Insert(cur, opt_trcode, code_option, 0,YYMM_ACT , G_sqldata) ## 데이터를 DB에 저장
next_YN = Sqlite.Check_next(trcode, G_sqldata, G_date_to) ## 반복수행여부 체크,
else :
print(code_option, "G_sqldata 업습니다")
next_YN = False
Loop_Count_Check (trcode,code_option) ## 키움제약사항에 걸리는지 체크 (일정시간내 크랜젝션 수 )
########## 데이터 연속조회 : comm_rq_data에서 remained_data 값이 결정되어 이후 while문 실행여부 결정 #######
while kiwoom.remained_data == True and next_YN == True:
kiwoom.set_input_value(input_list)
kiwoom.comm_rq_data(rqname, trcode, 2, scrno)
G_sqldata = kiwoom.G_sqldata
if len(G_sqldata) > 0:
DB_Insert(cur, opt_trcode, code_option, 0,YYMM_ACT ,G_sqldata)
next_YN = Sqlite.Check_next(trcode, G_sqldata, G_date_to)
Loop_Count_Check(trcode, code_option)
3. 기존 공통 프로그램 수정 및 모듈 신규 추가 작성
kiwoom = kw_class_kiwoom.Kiwoom() ### 키움 오픈API 사용객체 생성
Comm_Func = kw_Comm_Func.Comm_Func() ### 공통함수 객체 생성
Sqlite = kw_class_db_Insert.Sqlite_insert() ### Sqlite3 DB 데이처 저장 객체 생성
3-1) 기존 모듈 수정
3-1-1) Comm_Func.Get_Input_List 수정 : TR별 입력변수 추가
3-1-2) kiwoom.set_input_value(input_list) : 이 부분은 공통모듈화 해서 수정할 것이 없음
3-1-3) kiwoom.comm_rq_data(rqname, trcode, 0, scrno) : 이부분은 공통모듈화 해서 수정할 것이 없음
3-1-4) Sqlite.Check_next(trcode, G_sqldata, G_date_to) : 키움에서 제공받은 멀티데이터의 마지막 데이터 일자 체크
- 일자값이 원하는 기간을 벗어날때 까지 연속 수행할 수 있도록 일자항목 순서를 확인하여 체크되도록 수정
3-1-5) DB_Insert(cur, opt_trcode, code_option, 0,YYMM_ACT , G_sqldata) : 주요 수정 모듈 Set
3-1-5-1) Comm_Func.Get_Output_List(trcode) : 추가되는 TR코드 요청결과 반환되는 컬럼순서 세팅
3-1-5-2) Comm_Func.Get_Table_Name(trcode, YYMM_ACT ,0 ) : TR코드에 따라 데이터 저장할 테이블명 정의
3-1-5-3) Comm_Func.Get_DB_Colume_List(trcode) 수정 : 데이터 저장할 테이블의 컬럼명을 정의
3-1-5-4) Sqlite.Insert : TR코드에 따라 신규 호출할 모듈명과 인수들을 정의하고
3-2) 신규모듈 추가 작성 ( Sqlite.Insert 함수내에서 호출되는 )
def insert_50064(self, cur, trcode, code_option, G_sqldata, table_name, ret_column_list, table_columns, table_values):
if trcode == "OPT50064" or trcode == "OPT50062" : # OPT50064 : 선물/옵션미결제 약정 분차트요청
df = pd.DataFrame(G_sqldata, columns=ret_column_list)
df['종목코드'] = code_option
df['Y4mmdd_Update'] = self.updatedate
df['현재가'] = abs(pd.to_numeric(df['현재가']) ) # 현재값 절대값으로 ##20231226일 절대값변환 추가함
df = df[['종목코드', '체결시간' ,'현재가', '미결제약정', '미결제증감', 'Y4mmdd_Update']]
df_len = len(df) ## 데이터 존재 유무 체크하기 위하여 행수 확인
if df_len > 0:
df_to_list = df.values.tolist() ### 데이터프레임을 리스트로 변환
sql_insert = f"INSERT OR replace INTO {table_name} {table_columns} VALUES {table_values}"
sql_result = cur.executemany(sql_insert, (df_to_list)) ### 멀티데이터 Sqlite3에 한번에 저장