Skip to content

Instantly share code, notes, and snippets.

@AlJohri
Created December 6, 2015 05:40
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save AlJohri/5c56ce1bd92e529978e0 to your computer and use it in GitHub Desktop.
Save AlJohri/5c56ce1bd92e529978e0 to your computer and use it in GitHub Desktop.
import asyncio, pymongo, random, time, traceback
from blessings import Terminal
t = Terminal()
import motor.motor_asyncio, pymongo
client = motor.motor_asyncio.AsyncIOMotorClient("mongodb://localhost:27017/test")
asyncdb = client.get_default_database()
async def main():
await asyncdb.rand.drop()
for i in range(100000):
key = random.randint(1, 100000000)
obj = { "_id": key }
try:
await asyncdb.rand.insert(obj)
# print(t.green("{0} inserted into database".format(key)))
except pymongo.errors.DuplicateKeyError:
print(t.red("{0} already exists in database".format(key)))
except Exception as e:
traceback.print_stack()
import ipdb; ipdb.set_trace()
print(e)
start_time = time.time()
loop = asyncio.get_event_loop()
loop.set_debug(True)
loop.run_until_complete(main())
loop.close()
end_time = time.time()
print(100000 / (end_time - start_time))
@AlJohri
Copy link
Author

AlJohri commented Dec 6, 2015

pip install aiohttp motor blessings

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment