grid_file.py 文件源码

def __create_index(self, collection, index, unique):
        doc = await collection.find_one(projection={'_id': 1})
        if doc is None:
            indexes = list()
            try:
                async with await collection.list_indexes() as cursor:
                    async for index in cursor:
                        indexes.append(index)
            except OperationFailure:
                pass
            if index not in indexes:
                await collection.create_index(index, unique=unique)