python으로 증권사 open api 연동 중에 에러가 발생합니다

Question

안녕하세요. python을 사용해서 증권사 open api 연동하는 중에 에러가 발생하는데 왜 이러는걸까요? 코드는 이렇게 썼습니다. vscode에서는 현재 밑에 써논 오류가 발생하고 있습니다. Import &#34;PyQt5.QtWidgets&#34; could not be resolved Import &#34;PyQt5.QAxContainer&#34; coulde not be resolved Import &#34;PyQt5.QtCore&#34; could not be resolved Import &#34;pandas&#34; could not be resolved from source &#34;QAxWidget&#34; is not defined &#34;QEventLoop&#34; is not defined &#34;QApplication&#34; is not defined그리고 pycharm으로 실행을하면 현재 Anaconda는 64bit 환경입니다. 32bit 환경으로 실행하여 주시기 바랍니다 라는 것과 Fatal Python error: init_stdio_encoding: failed to get the Python codec name of the stdio encodingPython runtime state: core initializedLookupError: unknown encoding: x-windows-949 이렇게 나옵니다. 우선 anaconda prompt에서 anaconda 32비트를 설치해보려고 했습니다.set CONDA_FORCE_32BIT&#61;1conda create -n py39_32 python&#61;3.9.13 anacondaconda activate py39_32 이렇게 해봤는데 마지막에 설치가 끝나고 실행을 할 때 EnvironmentNameNotFound: Could not find conda environment: py36_32You can list all discoverable environments with conda info --envs 이런게 나오면서 실행이 제대로 되지 않습니다. 또 anconda prompt에서 pyqt5를 설치해봤는데 그래도 계속 같은 오류가 발생합니다. 어떻게 하면 해결할 수 있을까요?import sys from PyQt5.QtWidgets import * from PyQt5.QAxContainer import * from PyQt5.QtCore import * import logging.handlers import time from pandas import DataFrame is_64bits &#61; sys.maxsize > 2**32 if is_64bits: print('64bit 환경입니다.') else: print('32bit 환경입니다.') formatter &#61; logging.Formatter('[%(levelname)s|%(filename)s:%(lineno)s] %(asctime)s > %(message)s') logger &#61; logging.getLogger(&#34;crumbs&#34;) logger.setLevel(logging.DEBUG) streamHandler &#61; logging.StreamHandler() streamHandler.setFormatter(formatter) logger.addHandler(streamHandler) TR_REQ_TIME_INTERVAL &#61; 0.2 class Openapi(QAxWidget): def __init__(self): print(&#34;openapi __name__:&#34;, __name__) super().__init__() self._create_open_api_instance() self._set_signal_slots() self.comm_connect() self.account_info() def _opt10081(self, rqname, trcode): # 몇번 반복 실행 할지 설정 ohlcv_cnt &#61; self._get_repeat_cnt(trcode, rqname) # 하나의 row씩 append for i in range(ohlcv_cnt): date &#61; self._get_comm_data(trcode, rqname, i, &#34;일자&#34;) open &#61; self._get_comm_data(trcode, rqname, i, &#34;시가&#34;) high &#61; self._get_comm_data(trcode, rqname, i, &#34;고가&#34;) low &#61; self._get_comm_data(trcode, rqname, i, &#34;저가&#34;) close &#61; self._get_comm_data(trcode, rqname, i, &#34;현재가&#34;) volume &#61; self._get_comm_data(trcode, rqname, i, &#34;거래량&#34;) self.ohlcv['date'].append(date) self.ohlcv['open'].append(int(open)) self.ohlcv['high'].append(int(high)) self.ohlcv['low'].append(int(low)) self.ohlcv['close'].append(int(close)) self.ohlcv['volume'].append(int(volume)) def _receive_tr_data(self, screen_no, rqname, trcode, record_name, next, unused1, unused2, unused3, unused4): # print(&#34;_receive_tr_data!!!&#34;) # print(rqname, trcode, next) if next &#61;&#61; '2': self.remained_data &#61; True else: self.remained_data &#61; False if rqname &#61;&#61; &#34;opt10081_req&#34;: self._opt10081(rqname, trcode) elif rqname &#61;&#61; &#34;opw00001_req&#34;: # print(&#34;opw00001_req!!!&#34;) # print(&#34;Get an de_deposit!!!&#34;) self._opw00001(rqname, trcode) elif rqname &#61;&#61; &#34;opw00018_req&#34;: # print(&#34;opw00018_req!!!&#34;) # print(&#34;Get the possessed item !!!!&#34;) self._opw00018(rqname, trcode) elif rqname &#61;&#61; &#34;opt10074_req&#34;: # print(&#34;opt10074_req!!!&#34;) # print(&#34;Get the profit&#34;) self._opt10074(rqname, trcode) elif rqname &#61;&#61; &#34;opw00015_req&#34;: # print(&#34;opw00015_req!!!&#34;) # print(&#34;deal list!!!!&#34;) self._opw00015(rqname, trcode) elif rqname &#61;&#61; &#34;opt10076_req&#34;: # print(&#34;opt10076_req&#34;) # print(&#34;chegyul list!!!!&#34;) self._opt10076(rqname, trcode) elif rqname &#61;&#61; &#34;opt10073_req&#34;: # print(&#34;opt10073_req&#34;) # print(&#34;Get today profit !!!!&#34;) self._opt10073(rqname, trcode) elif rqname &#61;&#61; &#34;opt10080_req&#34;: # print(&#34;opt10080_req!!!&#34;) # print(&#34;Get an de_deposit!!!&#34;) self._opt10080(rqname, trcode) try: self.tr_event_loop.exit() except AttributeError: pass # get_total_data : 특정 종목의 일자별 거래 데이터 조회 함수 # 사용방법 # code: 종목코드(ex. '005930' ) # start : 기준일자. (ex. '20200424') &#61;> 20200424 일자 까지의 모든 open, high, low, close, volume 데이터 출력 def get_total_data(self, code, start): self.ohlcv &#61; {'date': [], 'open': [], 'high': [], 'low': [], 'close': [], 'volume': []} self.set_input_value(&#34;종목코드&#34;, code) self.set_input_value(&#34;기준일자&#34;, start) self.set_input_value(&#34;수정주가구분&#34;, 1) self.comm_rq_data(&#34;opt10081_req&#34;, &#34;opt10081&#34;, 0, &#34;0101&#34;) # 이 밑에는 한번만 가져오는게 아니고 싹다 가져오는거다. while self.remained_data &#61;&#61; True: # time.sleep(TR_REQ_TIME_INTERVAL) self.set_input_value(&#34;종목코드&#34;, code) self.set_input_value(&#34;기준일자&#34;, start) self.set_input_value(&#34;수정주가구분&#34;, 1) self.comm_rq_data(&#34;opt10081_req&#34;, &#34;opt10081&#34;, 2, &#34;0101&#34;) time.sleep(0.2) # data 비어있는 경우 if len(self.ohlcv) &#61;&#61; 0: return [] if self.ohlcv['date'] &#61;&#61; '': return [] df &#61; DataFrame(self.ohlcv, columns&#61;['open', 'high', 'low', 'close', 'volume'], index&#61;self.ohlcv['date']) return df # get_one_day_option_data : 특정 종목의 특정 일 open(시작가), high(최고가), low(최저가), close(종가), volume(거래량) 조회 함수 # 사용방법 # code : 종목코드 # start : 조회 일자 # option : open(시작가), high(최고가), low(최저가), close(종가), volume(거래량) def get_one_day_option_data(self, code, start, option): self.ohlcv &#61; {'date': [], 'open': [], 'high': [], 'low': [], 'close': [], 'volume': []} self.set_input_value(&#34;종목코드&#34;, code) self.set_input_value(&#34;기준일자&#34;, start) self.set_input_value(&#34;수정주가구분&#34;, 1) self.comm_rq_data(&#34;opt10081_req&#34;, &#34;opt10081&#34;, 0, &#34;0101&#34;) if self.ohlcv['date'] &#61;&#61; '': return False df &#61; DataFrame(self.ohlcv, columns&#61;['open', 'high', 'low', 'close', 'volume'], index&#61;self.ohlcv['date']) if option &#61;&#61; 'open': return df.iloc[0, 0] elif option &#61;&#61; 'high': return df.iloc[0, 1] elif option &#61;&#61; 'low': return df.iloc[0, 2] elif option &#61;&#61; 'close': return df.iloc[0, 3] elif option &#61;&#61; 'volume': return df.iloc[0, 4] else: return False def multi_601_get_ohlcv_daliy_craw(self, code, code_name, start): self.ohlcv &#61; {'index': [], 'date': [], 'open': [], 'high': [], 'low': [], 'close': [], 'volume': []} self.set_input_value(&#34;종목코드&#34;, code) self.set_input_value(&#34;기준일자&#34;, start) self.set_input_value(&#34;수정주가구분&#34;, 1) self.comm_rq_data(&#34;opt10081_req&#34;, &#34;opt10081&#34;, 0, &#34;0101&#34;) time.sleep(0.2) if self.ohlcv['date'][0] &#61;&#61; '': return [] if self.ohlcv['date'] &#61;&#61; '': return [] df &#61; DataFrame(self.ohlcv, columns&#61;['date', 'open', 'high', 'low', 'close', 'volume']) return df def account_info(self): account_number &#61; self.get_login_info(&#34;ACCNO&#34;) self.account_number &#61; account_number.split(';')[0] logger.debug(&#34;계좌번호: &#34; &#43; self.account_number) def get_login_info(self, tag): try: ret &#61; self.dynamicCall(&#34;GetLoginInfo(QString)&#34;, tag) time.sleep(TR_REQ_TIME_INTERVAL) return ret except Exception as e: logger.critical(e) def _create_open_api_instance(self): try: self.setControl(&#34;KHOPENAPI.KHOpenAPICtrl.1&#34;) except Exception as e: logger.critical(e) def _set_signal_slots(self): try: self.OnEventConnect.connect(self._event_connect) self.OnReceiveTrData.connect(self._receive_tr_data) self.OnReceiveMsg.connect(self._receive_msg) # 주문체결 시점에서 키움증권 서버가 발생시키는 OnReceiveChejanData 이벤트를 처리하는 메서드 self.OnReceiveChejanData.connect(self._receive_chejan_data) except Exception as e: is_64bits &#61; sys.maxsize > 2**32 if is_64bits: logger.critical('현재 Anaconda는 64bit 환경입니다. 32bit 환경으로 실행하여 주시기 바랍니다.') else: logger.critical(e) def _receive_chejan_data(self, gubun, item_cnt, fid_list): print(&#34;_receive_chejan_data!!!&#34;) print(&#34;gubun!!!&#34;) print(gubun) # 체결 data! if gubun &#61;&#61; &#34;0&#34;: print(&#34;in 체결 data!!!!!&#34;) order_num &#61; self.get_chejan_data(9203) code_name_temp &#61; self.get_chejan_data(302) code_name &#61; self.change_format3(code_name_temp) code &#61; self.codename_to_code(code_name) chegyul_fail_amount_temp &#61; self.get_chejan_data(902) order_gubun &#61; self.get_chejan_data(905) purchase_price &#61; self.get_chejan_data(10) if code !&#61; False and code !&#61; &#34;&#34; and code !&#61; 0 and code !&#61; &#34;0&#34;: if chegyul_fail_amount_temp !&#61; &#34;&#34;: if self.is_all_item_db_check(code) &#61;&#61; False: print(&#34;all_item_db에 매도 안 된 종목이 없음 ! 즉 신규다!!&#34;) if chegyul_fail_amount_temp &#61;&#61; &#34;0&#34;: print(&#34;완벽히 싹 다 체결됨!&#34;) self.db_to_all_item(order_num, code, code_name, 0, purchase_price) else: print(&#34;체결 되었지만 덜 체결 됨!&#34;) self.db_to_all_item(order_num, code, code_name, 1, purchase_price) elif order_gubun &#61;&#61; &#34;&#43;매수&#34;: if chegyul_fail_amount_temp !&#61; &#34;0&#34; and self.stock_chegyul_check(code) &#61;&#61; True: print(&#34;재매수던 매수던 미체결 수량이 남아있고, stock_chegyul_check True인 놈 / 즉, 계속 사야되는 종목!&#34;) pass elif chegyul_fail_amount_temp &#61;&#61; &#34;0&#34; and self.stock_chegyul_check(code) &#61;&#61; True: print(&#34;재매수던 매수던 미체결 수량이 없고, stock_chegyul_check True인 놈 / 즉, 매수 끝난 종목!&#34;) self.end_invest_count_check(code) elif self.stock_chegyul_check(code) &#61;&#61; False: print(&#34;현재 all db에 존재하고 체결 체크가 0인 종목, 재매수 하는 경우!&#34;) else: pass elif order_gubun &#61;&#61; &#34;-매도&#34;: if chegyul_fail_amount_temp &#61;&#61; &#34;0&#34;: print(&#34;all db에 존재하고 전량 매도하는 경우!&#34;) self.sell_final_check(code) else: print(&#34;all db에 존재하고 수량 남겨 놓고 매도하는 경우!&#34;) self.sell_chegyul_fail_check(code) else: pass else: print(&#34;_receive_chejan_data 에서 code 가 불량은 아닌데 체결된 종목이 빈공간인 경우!&#34;) else: print(&#34;_receive_chejan_data 에서 code가 불량이다!!&#34;) elif gubun &#61;&#61; &#34;1&#34;: print(&#34;잔고데이터!!!!!&#34;) chegyul_fail_amount_temp &#61; self.get_chejan_data(902) print(chegyul_fail_amount_temp) else: pass def comm_connect(self): try: self.dynamicCall(&#34;CommConnect()&#34;) time.sleep(TR_REQ_TIME_INTERVAL) self.login_event_loop &#61; QEventLoop() self.login_event_loop.exec_() except Exception as e: logger.critical(e) def _receive_msg(self, sScrNo, sRQName, sTrCode, sMsg): print(sMsg) def _event_connect(self, err_code): try: if err_code &#61;&#61; 0: logger.debug(&#34;connected&#34;) else: logger.debug(f&#34;disconnected. err_code : {err_code}&#34;) self.login_event_loop.exit() except Exception as e: logger.critical(e) def get_connect_state(self): try: ret &#61; self.dynamicCall(&#34;GetConnectState()&#34;) time.sleep(TR_REQ_TIME_INTERVAL) return ret except Exception as e: logger.critical(e) def set_input_value(self, id, value): try: self.dynamicCall(&#34;SetInputValue(QString, QString)&#34;, id, value) except Exception as e: logger.critical(e) def comm_rq_data(self, rqname, trcode, next, screen_no): self.dynamicCall(&#34;CommRqData(QString, QString, int, QString)&#34;, rqname, trcode, next, screen_no) time.sleep(TR_REQ_TIME_INTERVAL) self.tr_event_loop &#61; QEventLoop() self.tr_event_loop.exec_() def _get_comm_data(self, code, field_name, index, item_name): ret &#61; self.dynamicCall(&#34;GetCommData(QString, QString, int, QString)&#34;, code, field_name, index, item_name) return ret.strip() def _get_repeat_cnt(self, trcode, rqname): try: ret &#61; self.dynamicCall(&#34;GetRepeatCnt(QString, QString)&#34;, trcode, rqname) return ret except Exception as e: logger.critical(e) if __name__ &#61;&#61; &#34;__main__&#34;: app &#61; QApplication(sys.argv) Openapi()

고등어통조림 · Answer

일단 설치가 안 됐어요

python으로 증권사 open api 연동 중에 에러가 발생합니다

1개의 답변

#anaconda 목록