質問編集履歴

抜けていたプログラムコードの追記。

2019/05/12 12:48

投稿

wiz_planet

スコア13

test CHANGED Viewed

File without changes

test CHANGED Viewed

@@ -395,3 +395,43 @@
 ```
+### 追記２
+```
+※抜けていたプログラムコードを追記します。
+```
+### 該当のソースコード２
+```python
+# API 接続
+def make_connection():
+    #API endpoint
+    url = 'URL'
+    channel = '希望するAPI情報の種類(str)'
+    json_rpc = WebsocketAPI(url=url, channel=channel)
+    print("json_rpc : ", json_rpc)
+    return url, channel, json_rpc
+```

初回エラーは解決しましたが、別のエラーが発生したためエラーとコードを追記しました。

2019/05/12 12:48

投稿

wiz_planet

スコア13

test CHANGED Viewed

File without changes

test CHANGED Viewed

@@ -46,6 +46,274 @@
 # サブプロセス
+def test_func(d):
+    print("in test_func started")
+    d[1] = 200
+    print(d[1])
+    d["test"] = "test1"
+    print(d["test"])
+    while True:
+        print(d)
+        sleep(0.5)
+if __name__ == '__main__':
+    while True:
+        try:
+            with Manager() as manager:
+                d = manager.dict()
+                test_process = Process(target=test_func, args=(d))
+                print("start")
+                test_process.start()
+                print("finished")
+                break
+        except ccxt.BaseError as e:
+            print(" error in SubProcess : test_func()",e)
+            print("recall")
+            sleep(1)
+    #API endpoint
+    url, channel, json_rpc = make_connection()
+    #ctrl + cで終了
+    while True:
+        try:
+            json_rpc.run()
+            break
+        except ccxt.BaseError as e:
+            print(" error in _MAIN_ json_rpc.run()", e)
+            url, channel, json_rpc = make_connection()
+```
+### 発生している問題・エラーメッセージ
+```
+(base) C:\test>python websocket.py
+start
+finished
+called ＿init＿
+websocket.WebSocketApp open 正常終了
+json_rpc :  <__main__.RealtimeAPI object at 0x0000023E460B6D68>
+--- request header ---
+-----------------------
+--- response header ---
+-----------------------
+called on_open
+connected streaming server
+send: b'\x81\xd1\x8b\xd1t\xbf\xf0\xf3\x19\xda\xff\xb9\x1b\xdb\xa9\xebT\x9d\xf8\xa4\x16\xcc\xe8\xa3\x1d\xdd\xee\xf3X\x9f\xa9\xa1\x15\xcd\xea\xbc\x07\x9d\xb1\xf1\x0f\x9d\xe8\xb9\x15\xd1\xe5\xb4\x18\x9d\xb1\xf1V\xd3\xe2\xb6\x1c\xcb\xe5\xb8\x1a\xd8\xd4\xb4\x0c\xda\xe8\xa4\x00\xd6\xe4\xbf\x07\xe0\xcd\x89+\xfd\xdf\x92+\xf5\xdb\x88V\xc2\xf6'
+～～～～～～～～～～～～
+～～ websocket 処理～～
+～～～～～～～～～～～～
+～～～～～～～～～～～サブプロセスエラー～～～～～～～～～～～～～～～～
+Process Process-2:
+Traceback (most recent call last):
+  File "C:\Anaconda3_2\lib\multiprocessing\process.py", line 297, in _bootstrap
+    self.run()
+  File "C:\Anaconda3_2\lib\multiprocessing\process.py", line 99, in run
+    self._target(*self._args, **self._kwargs)
+TypeError: test_func() missing 1 required positional argument: 'd'
+～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～
+～～～～～～～～～～～～
+～～ websocket 処理～～
+～～～～～～～～～～～～
+```
+サブプロセスについては最初のプリント文すら表示されません。
+何が原因かわかれば教えてください。よろしくお願いします。
+### 追記
+```
+初期エラーが改善され、次のエラーが生じたため編集コードとエラーを抜粋して追記します。
+またサブプロセス１行目のプリント文までは出力されるようになりました。
+引き続きよろしくお願いします。
+```
+### 発生している問題・エラーメッセージ２
+```
+～～～～～～～～～～～サブプロセスエラー～～～～～～～～～～～～～～～～
+in test_func started
+Process Process-2:
+Traceback (most recent call last):
+  File "C:\Anaconda3_2\lib\multiprocessing\managers.py", line 788, in _callmethod
+    conn = self._tls.connection
+AttributeError: 'ForkAwareLocal' object has no attribute 'connection'
+During handling of the above exception, another exception occurred:
+Traceback (most recent call last):
+  File "C:\Anaconda3_2\lib\multiprocessing\process.py", line 297, in _bootstrap
+    self.run()
+  File "C:\Anaconda3_2\lib\multiprocessing\process.py", line 99, in run
+    self._target(*self._args, **self._kwargs)
+  File "C:\test\websocket.py", line 563, in test_func
+    d[1] = 200
+  File "<string>", line 2, in __setitem__
+  File "C:\Anaconda3_2\lib\multiprocessing\managers.py", line 792, in _callmethod
+    self._connect()
+  File "C:\Anaconda3_2\lib\multiprocessing\managers.py", line 779, in _connect
+    conn = self._Client(self._token.address, authkey=self._authkey)
+  File "C:\Anaconda3_2\lib\multiprocessing\connection.py", line 490, in Client
+    c = PipeClient(address)
+  File "C:\Anaconda3_2\lib\multiprocessing\connection.py", line 691, in PipeClient
+    _winapi.WaitNamedPipe(address, 1000)
+FileNotFoundError: [WinError 2] 指定されたファイルが見つかりません。
+～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～
+```
+### 該当のソースコード
+```python
+# サブプロセス
+# 変数を２つに修正
 def test_func(d,l):
     print("in test_func")
@@ -68,8 +336,6 @@
 if __name__ == '__main__':
@@ -82,6 +348,8 @@
                 d = manager.dict()
+                ### 変数 l を追加 ###
                 l = manager.list(range(5))
                 test_process = Process(target=test_func, args=(d,l))
@@ -127,129 +395,3 @@
 ```
-### 発生している問題・エラーメッセージ
-```
-(base) C:\test>python websocket.py
-start
-finished
-called ＿init＿
-websocket.WebSocketApp open 正常終了
-json_rpc :  <__main__.RealtimeAPI object at 0x0000023E460B6D68>
---- request header ---
------------------------
---- response header ---
------------------------
-called on_open
-connected streaming server
-send: b'\x81\xd1\x8b\xd1t\xbf\xf0\xf3\x19\xda\xff\xb9\x1b\xdb\xa9\xebT\x9d\xf8\xa4\x16\xcc\xe8\xa3\x1d\xdd\xee\xf3X\x9f\xa9\xa1\x15\xcd\xea\xbc\x07\x9d\xb1\xf1\x0f\x9d\xe8\xb9\x15\xd1\xe5\xb4\x18\x9d\xb1\xf1V\xd3\xe2\xb6\x1c\xcb\xe5\xb8\x1a\xd8\xd4\xb4\x0c\xda\xe8\xa4\x00\xd6\xe4\xbf\x07\xe0\xcd\x89+\xfd\xdf\x92+\xf5\xdb\x88V\xc2\xf6'
-～～～～～～～～～～～～
-～～ websocket 処理～～
-～～～～～～～～～～～～
-～～～～～～～～～～～サブプロセスエラー～～～～～～～～～～～～～～～～
-in test_func
-Process Process-2:
-Traceback (most recent call last):
-  File "C:\Anaconda3_2\lib\multiprocessing\managers.py", line 788, in _callmethod
-    conn = self._tls.connection
-AttributeError: 'ForkAwareLocal' object has no attribute 'connection'
-During handling of the above exception, another exception occurred:
-Traceback (most recent call last):
-  File "C:\Anaconda3_2\lib\multiprocessing\process.py", line 297, in _bootstrap
-    self.run()
-  File "C:\Anaconda3_2\lib\multiprocessing\process.py", line 99, in run
-    self._target(*self._args, **self._kwargs)
-  File "C:\test\websocket.py", line 563, in test_func
-    d[1] = 200
-  File "<string>", line 2, in __setitem__
-  File "C:\Anaconda3_2\lib\multiprocessing\managers.py", line 792, in _callmethod
-    self._connect()
-  File "C:\Anaconda3_2\lib\multiprocessing\managers.py", line 779, in _connect
-    conn = self._Client(self._token.address, authkey=self._authkey)
-  File "C:\Anaconda3_2\lib\multiprocessing\connection.py", line 490, in Client
-    c = PipeClient(address)
-  File "C:\Anaconda3_2\lib\multiprocessing\connection.py", line 691, in PipeClient
-    _winapi.WaitNamedPipe(address, 1000)
-FileNotFoundError: [WinError 2] 指定されたファイルが見つかりません。
-～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～
-～～～～～～～～～～～～
-～～ websocket 処理～～
-～～～～～～～～～～～～
-```
-引き続きサブプロセスについては最初のプリント文すら表示されません。
-何が原因かわかれば教えてください。よろしくお願いします。

初回のエラーは解消されて次のエラーが生じたため修正しました

2019/05/12 12:16

投稿

wiz_planet

スコア13

test CHANGED Viewed

File without changes

test CHANGED Viewed

@@ -46,18 +46,24 @@
 # サブプロセス
-def test_func(d):
+def test_func(d,l):
     print("in test_func")
     d[1] = 200
+    print(d[1])
     d["test"] = "test1"
+    print(d["test"])
     while True:
         print(d)
+        print(l)
         sleep(0.5)
@@ -76,7 +82,9 @@
                 d = manager.dict()
+                l = manager.list(range(5))
-                test_process = Process(target=test_func, args=(d))
+                test_process = Process(target=test_func, args=(d,l))
                 print("start")
@@ -170,19 +178,59 @@
 ～～～～～～～～～～～サブプロセスエラー～～～～～～～～～～～～～～～～
+in test_func
 Process Process-2:
 Traceback (most recent call last):
+  File "C:\Anaconda3_2\lib\multiprocessing\managers.py", line 788, in _callmethod
+    conn = self._tls.connection
+AttributeError: 'ForkAwareLocal' object has no attribute 'connection'
+During handling of the above exception, another exception occurred:
+Traceback (most recent call last):
-  File "C:\Users\k-tanabe\Anaconda3_2\lib\multiprocessing\process.py", line 297, in _bootstrap
+  File "C:\Anaconda3_2\lib\multiprocessing\process.py", line 297, in _bootstrap
     self.run()
-  File "C:\Users\k-tanabe\Anaconda3_2\lib\multiprocessing\process.py", line 99, in run
+  File "C:\Anaconda3_2\lib\multiprocessing\process.py", line 99, in run
     self._target(*self._args, **self._kwargs)
+  File "C:\test\websocket.py", line 563, in test_func
+    d[1] = 200
+  File "<string>", line 2, in __setitem__
+  File "C:\Anaconda3_2\lib\multiprocessing\managers.py", line 792, in _callmethod
+    self._connect()
+  File "C:\Anaconda3_2\lib\multiprocessing\managers.py", line 779, in _connect
+    conn = self._Client(self._token.address, authkey=self._authkey)
-TypeError: test_func() missing 1 required positional argument: 'd'
+  File "C:\Anaconda3_2\lib\multiprocessing\connection.py", line 490, in Client
+    c = PipeClient(address)
+  File "C:\Anaconda3_2\lib\multiprocessing\connection.py", line 691, in PipeClient
+    _winapi.WaitNamedPipe(address, 1000)
+FileNotFoundError: [WinError 2] 指定されたファイルが見つかりません。
 ～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～～
@@ -202,6 +250,6 @@
-サブプロセスについては最初のプリント文すら表示されません。
+引き続きサブプロセスについては最初のプリント文すら表示されません。
 何が原因かわかれば教えてください。よろしくお願いします。