質問編集履歴

2

質問変更

2021/03/08 09:07

投稿

pokemonta
pokemonta

スコア170

test CHANGED
File without changes
test CHANGED
@@ -56,7 +56,7 @@
56
56
 
57
57
 
58
58
 
59
- tpe = ThreadPoolExecutor(max_workers=2, thread_name_prefix="thread")
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["items"]);
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
- destUnboundLocalErrorが発生ます。
157
+ どんなデータが取得きるのか細かく記載ていないため
156
158
 
157
- た、最終的に1つのjsonにマージるところわかりません。
159
+ 回答が難しいとは思いますが
158
160
 
159
- devIdを渡して並列に処理させた結果を
160
-
161
- 最終的どのようにjson.dumpsさせるのでしょうか
161
+ 実装方法問題があるのでしょうか

1

goki

2021/03/08 09:07

投稿

pokemonta
pokemonta

スコア170

test CHANGED
File without changes
test CHANGED
@@ -52,7 +52,7 @@
52
52
 
53
53
 
54
54
 
55
- def lambda_handler(event, context):
55
+ def lambda_handler(devIdList):
56
56
 
57
57
 
58
58