Method _create

pymongo/asynchronous/collection.py:671–696

(
        self,
        options: MutableMapping[str, Any],
        session: Optional[AsyncClientSession],
    )

        await self.database.client._retryable_write(False, inner, session, _Op.CREATE)

    async def _create(
        self,
        options: MutableMapping[str, Any],
        session: Optional[AsyncClientSession],
    ) -> None:
        collation = validate_collation_or_none(options.pop("collation", None))
        encrypted_fields = options.pop("encryptedFields", None)
        if encrypted_fields:
            common.validate_is_mapping("encrypted_fields", encrypted_fields)
            opts = {"clusteredIndex": {"key": {"_id": 1}, "unique": True}}
            await self._create_helper(
                _esc_coll_name(encrypted_fields, self._name),
                opts,
                None,
                session,
                qev2_required=True,
            )
            await self._create_helper(
                _ecoc_coll_name(encrypted_fields, self._name), opts, None, session
            )
            await self._create_helper(
                self._name, options, collation, session, encrypted_fields=encrypted_fields
            )
            await self.create_index([("__safeContent__", ASCENDING)], session)
        else:
            await self._create_helper(self._name, options, collation, session)

    @_csot.apply
    async def bulk_write(