sina行情的获得改为使用 aiohttp

imbugs · Jan 14, 2016 · 192bfd5 · 192bfd5
1 parent ce319ab
commit 192bfd5
Showing 1 changed file with 4 additions and 5 deletions.
diff --git a/easyquotation/sina.py b/easyquotation/sina.py
@@ -1,8 +1,7 @@
 import re
 import json
-import time
 import asyncio
-import requests
+import aiohttp
 from . import helpers
 
 
@@ -39,9 +38,9 @@ def all(self):
         return self.get_stock_data()
 
     async def get_stocks_by_range(self, index):
-        loop = asyncio.get_event_loop()
-        response = await loop.run_in_executor(None, requests.get, self.sina_stock_api + self.stock_list[index])
-        self.stock_data.append(response.text)
+        async with aiohttp.get(self.sina_stock_api + self.stock_list[index]) as r:
+            response_text = await r.text()
+            self.stock_data.append(response_text)
 
     def get_stock_data(self):
         threads = []