django3.0 использует каналы и хранит данные mongdob - PullRequest
Новая
       78

django3.0 использует каналы и хранит данные mongdob

0 голосов
/ 24 февраля 2020

django3.0 использовать каналы и mongdob хранить данные, которые я хочу asyn c вставить данные для mongodb 

from channels.db import database_sync_to_async
import time
import pymongo
conn = pymongo.MongoClient('xxxx', 27017)

db = conn['test']

async def  insert():
    time.sleep(1)
    print(1111111)
    resul =await db.test_collection.insert_many([{'key': "key{}".format(i)} for i in range(10)])



class Index(View):
    def get(self, request):
        print(2222222)
        loop = asyncio.get_event_loop()
        loop.run_until_complete(insert)
        print(333333333)
        return JsonResponse({'1': 111})

ошибка повышения 

    raise NotImplementedError
NotImplementedError
...