質問編集履歴
2
質問変更
test
CHANGED
File without changes
|
test
CHANGED
@@ -56,7 +56,7 @@
|
|
56
56
|
|
57
57
|
|
58
58
|
|
59
|
-
tpe = ThreadPoolExecutor(max_workers=
|
59
|
+
tpe = ThreadPoolExecutor(max_workers=len(devIdList), thread_name_prefix="thread")
|
60
60
|
|
61
61
|
result = list();
|
62
62
|
|
@@ -66,13 +66,15 @@
|
|
66
66
|
|
67
67
|
future = tpe.submit(main,devId)
|
68
68
|
|
69
|
-
result.append(future
|
69
|
+
result.append(future);
|
70
70
|
|
71
71
|
tpe.shutdown()
|
72
72
|
|
73
73
|
|
74
74
|
|
75
75
|
for future in result:
|
76
|
+
|
77
|
+
List.append(future.result())
|
76
78
|
|
77
79
|
|
78
80
|
|
@@ -86,7 +88,7 @@
|
|
86
88
|
|
87
89
|
},
|
88
90
|
|
89
|
-
"body": json.dumps(
|
91
|
+
"body": json.dumps([i for i in List])
|
90
92
|
|
91
93
|
}
|
92
94
|
|
@@ -150,12 +152,10 @@
|
|
150
152
|
|
151
153
|
```
|
152
154
|
|
153
|
-
し
|
155
|
+
マルチプロセスを実装しても性能が全然向上しません。
|
154
156
|
|
155
|
-
|
157
|
+
どんなデータが取得できるのか細かく記載していないため
|
156
158
|
|
157
|
-
ま
|
159
|
+
回答が難しいとは思いますが
|
158
160
|
|
159
|
-
devIdを渡して並列に処理させた結果を
|
160
|
-
|
161
|
-
|
161
|
+
実装方法に問題があるのでしょうか
|
1
goki
test
CHANGED
File without changes
|
test
CHANGED
@@ -52,7 +52,7 @@
|
|
52
52
|
|
53
53
|
|
54
54
|
|
55
|
-
def lambda_handler(ev
|
55
|
+
def lambda_handler(devIdList):
|
56
56
|
|
57
57
|
|
58
58
|
|