aAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA

This commit is contained in:
TheTechRobo 2022-04-03 14:13:41 -04:00
parent b5b47c98e1
commit de7c6beb2e
1 changed files with 2 additions and 1 deletions

View File

@ -1,4 +1,4 @@
import asyncio, websockets,time,json, requests, rethinkdb, aiohttp
import asyncio, websockets,time,json, requests, rethinkdb, aiohttp, sys
from rethinkdb import r
import raw_data
@ -54,6 +54,7 @@ class PlaceScraper:
await ws.send(raw_data.id1)
await ws.send(raw_data.id2)
async def run_forever(self):
global STOP, STOPPED
connector = aiohttp.TCPConnector(limit=25)
async with websockets.connect("wss://gql-realtime-2.reddit.com/query", extra_headers=[["Origin", "https://hot-potato.reddit.com"], ["User-Agent", "Mozilla"]]) as websocket:
await self._start_connection(websocket)