質問をすることでしか得られない、回答やアドバイスがある。

15分調べてもわからないことは、質問しよう!

新規登録して質問してみよう
ただいま回答率
85.49%
Python

Pythonは、コードの読みやすさが特徴的なプログラミング言語の1つです。 強い型付け、動的型付けに対応しており、後方互換性がないバージョン2系とバージョン3系が使用されています。 商用製品の開発にも無料で使用でき、OSだけでなく仮想環境にも対応。Unicodeによる文字列操作をサポートしているため、日本語処理も標準で可能です。

Q&A

解決済

1回答

2229閲覧

ddeclient.pyの167行目でDDE.ClientTransactionがFalseと値を返しているみたいなのですが

yudaiyamashita

総合スコア10

Python

Pythonは、コードの読みやすさが特徴的なプログラミング言語の1つです。 強い型付け、動的型付けに対応しており、後方互換性がないバージョン2系とバージョン3系が使用されています。 商用製品の開発にも無料で使用でき、OSだけでなく仮想環境にも対応。Unicodeによる文字列操作をサポートしているため、日本語処理も標準で可能です。

0グッド

0クリップ

投稿2021/12/13 05:38

編集2022/01/20 15:21

rakuten_rssを使って株価を取得しようとすると、
fail: code@ 9501.T
と表示されます。
DDE通信?を使っているらしいです。
pdb(後述)を使ってデバッグをしました。

ddeclient.pyのrequest関数の中で条件分岐で
if not hDdeData:
raise DDEError("Unable to request item", self._idInst)
hDdeDataがFalseみたいです。
self._idInstとhszItemはきちんと値が入っています。

どうすればいいでしょうか。

ddeclient.pyの一部

ddeclient.pyの一部

1from ctypes import POINTER, WINFUNCTYPE, c_char_p, c_void_p, c_int, c_ulong, c_char_p 2from ctypes.wintypes import BOOL, DWORD, BYTE, INT, LPCWSTR, UINT, ULONG 3 4# DECLARE_HANDLE(name) typedef void *name; 5HCONV = c_void_p # = DECLARE_HANDLE(HCONV) 6HDDEDATA = c_void_p # = DECLARE_HANDLE(HDDEDATA) 7HSZ = c_void_p # = DECLARE_HANDLE(HSZ) 8LPBYTE = c_char_p # POINTER(BYTE) 9LPDWORD = POINTER(DWORD) 10LPSTR = c_char_p 11ULONG_PTR = c_ulong 12 13# See windows/ddeml.h for declaration of struct CONVCONTEXT 14PCONVCONTEXT = c_void_p 15 16DMLERR_NO_ERROR = 0 17 18# Predefined Clipboard Formats 19CF_TEXT = 1 20CF_BITMAP = 2 21CF_METAFILEPICT = 3 22CF_SYLK = 4 23CF_DIF = 5 24CF_TIFF = 6 25CF_OEMTEXT = 7 26CF_DIB = 8 27CF_PALETTE = 9 28CF_PENDATA = 10 29CF_RIFF = 11 30CF_WAVE = 12 31CF_UNICODETEXT = 13 32CF_ENHMETAFILE = 14 33CF_HDROP = 15 34CF_LOCALE = 16 35CF_DIBV5 = 17 36CF_MAX = 18 37 38DDE_FACK = 0x8000 39DDE_FBUSY = 0x4000 40DDE_FDEFERUPD = 0x4000 41DDE_FACKREQ = 0x8000 42DDE_FRELEASE = 0x2000 43DDE_FREQUESTED = 0x1000 44DDE_FAPPSTATUS = 0x00FF 45DDE_FNOTPROCESSED = 0x0000 46 47DDE_FACKRESERVED = (~(DDE_FACK | DDE_FBUSY | DDE_FAPPSTATUS)) 48DDE_FADVRESERVED = (~(DDE_FACKREQ | DDE_FDEFERUPD)) 49DDE_FDATRESERVED = (~(DDE_FACKREQ | DDE_FRELEASE | DDE_FREQUESTED)) 50DDE_FPOKRESERVED = (~(DDE_FRELEASE)) 51 52XTYPF_NOBLOCK = 0x0002 53XTYPF_NODATA = 0x0004 54XTYPF_ACKREQ = 0x0008 55 56XCLASS_MASK = 0xFC00 57XCLASS_BOOL = 0x1000 58XCLASS_DATA = 0x2000 59XCLASS_FLAGS = 0x4000 60XCLASS_NOTIFICATION = 0x8000 61 62XTYP_ERROR = (0x0000 | XCLASS_NOTIFICATION | XTYPF_NOBLOCK) 63XTYP_ADVDATA = (0x0010 | XCLASS_FLAGS) 64XTYP_ADVREQ = (0x0020 | XCLASS_DATA | XTYPF_NOBLOCK) 65XTYP_ADVSTART = (0x0030 | XCLASS_BOOL) 66XTYP_ADVSTOP = (0x0040 | XCLASS_NOTIFICATION) 67XTYP_EXECUTE = (0x0050 | XCLASS_FLAGS) 68XTYP_CONNECT = (0x0060 | XCLASS_BOOL | XTYPF_NOBLOCK) 69XTYP_CONNECT_CONFIRM = (0x0070 | XCLASS_NOTIFICATION | XTYPF_NOBLOCK) 70XTYP_XACT_COMPLETE = (0x0080 | XCLASS_NOTIFICATION ) 71XTYP_POKE = (0x0090 | XCLASS_FLAGS) 72XTYP_REGISTER = (0x00A0 | XCLASS_NOTIFICATION | XTYPF_NOBLOCK ) 73XTYP_REQUEST = (0x00B0 | XCLASS_DATA ) 74XTYP_DISCONNECT = (0x00C0 | XCLASS_NOTIFICATION | XTYPF_NOBLOCK ) 75XTYP_UNREGISTER = (0x00D0 | XCLASS_NOTIFICATION | XTYPF_NOBLOCK ) 76XTYP_WILDCONNECT = (0x00E0 | XCLASS_DATA | XTYPF_NOBLOCK) 77XTYP_MONITOR = (0x00F0 | XCLASS_NOTIFICATION | XTYPF_NOBLOCK) 78 79XTYP_MASK = 0x00F0 80XTYP_SHIFT = 4 81 82TIMEOUT_ASYNC = 0xFFFFFFFF 83 84def get_winfunc(libname, funcname, restype=None, argtypes=(), _libcache={}): 85 """Retrieve a function from a library, and set the data types.""" 86 from ctypes import windll 87 88 if libname not in _libcache: 89 _libcache[libname] = windll.LoadLibrary(libname) 90 func = getattr(_libcache[libname], funcname) 91 func.argtypes = argtypes 92 func.restype = restype 93 94 return func 95 96 97DDECALLBACK = WINFUNCTYPE(HDDEDATA, UINT, UINT, HCONV, HSZ, HSZ, HDDEDATA, 98 ULONG_PTR, ULONG_PTR) 99 100class DDE(object): 101 """Object containing all the DDE functions""" 102 AccessData = get_winfunc("user32", "DdeAccessData", LPBYTE, (HDDEDATA, LPDWORD)) 103 ClientTransaction = get_winfunc("user32", "DdeClientTransaction", HDDEDATA, (LPBYTE, DWORD, HCONV, HSZ, UINT, UINT, DWORD, LPDWORD)) 104 Connect = get_winfunc("user32", "DdeConnect", HCONV, (DWORD, HSZ, HSZ, PCONVCONTEXT)) 105 CreateStringHandle = get_winfunc("user32", "DdeCreateStringHandleW", HSZ, (DWORD, LPCWSTR, UINT)) 106 Disconnect = get_winfunc("user32", "DdeDisconnect", BOOL, (HCONV,)) 107 GetLastError = get_winfunc("user32", "DdeGetLastError", UINT, (DWORD,)) 108 Initialize = get_winfunc("user32", "DdeInitializeW", UINT, (LPDWORD, DDECALLBACK, DWORD, DWORD)) 109 FreeDataHandle = get_winfunc("user32", "DdeFreeDataHandle", BOOL, (HDDEDATA,)) 110 FreeStringHandle = get_winfunc("user32", "DdeFreeStringHandle", BOOL, (DWORD, HSZ)) 111 QueryString = get_winfunc("user32", "DdeQueryStringA", DWORD, (DWORD, HSZ, LPSTR, DWORD, c_int)) 112 UnaccessData = get_winfunc("user32", "DdeUnaccessData", BOOL, (HDDEDATA,)) 113 Uninitialize = get_winfunc("user32", "DdeUninitialize", BOOL, (DWORD,)) 114 115class DDEError(RuntimeError): 116 """Exception raise when a DDE errpr occures.""" 117 def __init__(self, msg, idInst=None): 118 if idInst is None: 119 RuntimeError.__init__(self, msg) 120 else: 121 RuntimeError.__init__(self, "%s (err=%s)" % (msg, hex(DDE.GetLastError(idInst)))) 122 123class DDEClient(object): 124 """The DDEClient class. 125 126 Use this class to create and manage a connection to a service/topic. To get 127 classbacks subclass DDEClient and overwrite callback.""" 128 129 def __init__(self, service, topic): 130 """Create a connection to a service/topic.""" 131 from ctypes import byref 132 self._idInst = DWORD(0) 133 self._hConv = HCONV() 134 self._callback = DDECALLBACK(self._callback) 135 res = DDE.Initialize(byref(self._idInst), self._callback, 0x00000010, 0) 136 if res != DMLERR_NO_ERROR: 137 raise DDEError("Unable to register with DDEML (err=%s)" % hex(res)) 138 hszService = DDE.CreateStringHandle(self._idInst, service, 1200) 139 hszTopic = DDE.CreateStringHandle(self._idInst, topic, 1200) 140 self._hConv = DDE.Connect(self._idInst, hszService, hszTopic, PCONVCONTEXT()) 141 DDE.FreeStringHandle(self._idInst, hszTopic) 142 DDE.FreeStringHandle(self._idInst, hszService) 143 if not self._hConv: 144 raise DDEError("Unable to establish a conversation with server", self._idInst) 145 146 def __del__(self): 147 """Cleanup any active connections.""" 148 if self._hConv: 149 DDE.Disconnect(self._hConv) 150 if self._idInst: 151 DDE.Uninitialize(self._idInst) 152 153 def advise(self, item, stop=False): 154 """Request updates when DDE data changes.""" 155 from ctypes import byref 156 hszItem = DDE.CreateStringHandle(self._idInst, item, 1200) 157 hDdeData = DDE.ClientTransaction(LPBYTE(), 0, self._hConv, hszItem, CF_TEXT, XTYP_ADVSTOP if stop else XTYP_ADVSTART, TIMEOUT_ASYNC, LPDWORD()) 158 DDE.FreeStringHandle(self._idInst, hszItem) 159 if not hDdeData: 160 raise DDEError("Unable to %s advise" % ("stop" if stop else "start"), self._idInst) 161 DDE.FreeDataHandle(hDdeData) 162 163 def execute(self, command, timeout=5000): 164 """Execute a DDE command.""" 165 pData = c_char_p(command) 166 cbData = DWORD(len(command) + 1) 167 hDdeData = DDE.ClientTransaction(pData, cbData, self._hConv, HSZ(), CF_TEXT, XTYP_EXECUTE, timeout, LPDWORD()) 168 if not hDdeData: 169 raise DDEError("Unable to send command", self._idInst) 170 DDE.FreeDataHandle(hDdeData) 171 172 def request(self, item, timeout=5000): 173 """Request data from DDE service.""" 174 from ctypes import byref 175 hszItem = DDE.CreateStringHandle(self._idInst, item, 1200) 176 hDdeData = DDE.ClientTransaction(LPBYTE(), 0, self._hConv, hszItem, CF_TEXT, XTYP_REQUEST, timeout, LPDWORD()) 177 DDE.FreeStringHandle(self._idInst, hszItem) 178 print(self._hConv, hszItem) 179 if not hDdeData: 180 raise DDEError("Unable to request item", self._idInst) 181 182 if timeout != TIMEOUT_ASYNC: 183 pdwSize = DWORD(0) 184 pData = DDE.AccessData(hDdeData, byref(pdwSize)) 185 if not pData: 186 DDE.FreeDataHandle(hDdeData) 187 raise DDEError("Unable to access data", self._idInst) 188 # TODO: use pdwSize 189 DDE.UnaccessData(hDdeData) 190 else: 191 pData = None 192 DDE.FreeDataHandle(hDdeData) 193 return pData

rakuten_rss.pyのコード

Python

1from lib.ddeclient import DDEClient 2 3 4def rss(code, item): 5 dde = DDEClient("rss", str(code)) 6 try: 7 res = dde.request(item).decode('sjis').strip() 8 except: 9 print('fail: code@', code) 10 res = 0 11 finally: 12 dde.__del__() 13 return res 14 15 16def rss_dict(code, *args): 17 dde = DDEClient("rss", str(code)) 18 res = {} 19 try: 20 for item in args: 21 res[item] = dde.request(item).decode('sjis').strip() 22 except: 23 print('fail: code@', code) 24 res = {} 25 finally: 26 dde.__del__() 27 return res 28 29 30def fetch_open(code): 31 """ 始値を返す(SQ計算用に関数切り出し,入力int) 32 33 Parameters 34 ---------- 35 code : int 36 Examples 37 --------- 38 >>> fetch_open(9551) 39 50050 40 """ 41 42 return float(rss(str(code) + '.T', '始値'))

powershell

1python -m pdb request.py

と実行し、
イメージ説明
イメージ説明
イメージ説明
イメージ説明

気になる質問をクリップする

クリップした質問は、後からいつでもMYページで確認できます。

またクリップした質問に回答があった際、通知やメールを受け取ることができます。

バッドをするには、ログインかつ

こちらの条件を満たす必要があります。

guest

回答1

0

自己解決

Marcket Speed2ではなくMarcket Speedならばうまくいきました。

投稿2022/01/20 06:21

yudaiyamashita

総合スコア10

バッドをするには、ログインかつ

こちらの条件を満たす必要があります。

あなたの回答

tips

太字

斜体

打ち消し線

見出し

引用テキストの挿入

コードの挿入

リンクの挿入

リストの挿入

番号リストの挿入

表の挿入

水平線の挿入

プレビュー

15分調べてもわからないことは
teratailで質問しよう!

ただいまの回答率
85.49%

質問をまとめることで
思考を整理して素早く解決

テンプレート機能で
簡単に質問をまとめる

質問する

関連した質問