Docs Menu
Docs Home
/
언어
/
Python
/
PyMongo

PyMongo 에서 PyMongo 비동기로 전환

이 페이지의 내용

  • 개요
  • PyMongo 에서 전환
  • 비동기식 메서드
  • 추가 정보

중요

PyMongo 비동기 운전자 는 실험용이므로 프로덕션 환경에서는 사용해서는 안 됩니다. 이 가이드 에 설명된 클래스, 메서드 및 동작은 전체 출시하다 이전에 변경될 수 있습니다. PyMongo Async에 문제가 발생하는 경우 문제 및 도움말 페이지에서 문제를 보고하는 방법을 학습 수 있습니다.

개요

PyMongo PyMongo 비동기 운전자 는 PyMongo PyMongo 와 모터Motor 라이브러리를 통합한 것입니다. 이 가이드 에서는 PyMongo 에서 PyMongo 비동기로 전환하기 위해 수행해야 하는 변경 사항을 확인할 수 있습니다.

PyMongo 에서 전환

PyMongo 비동기 운전자 는 PyMongo 와 유사하게 동작하지만 네트워크 작업을 수행하는 모든 메서드는 코루틴이므로 대기해야 합니다. PyMongo 에서 PyMongo 비동기로 전환하려면 다음과 같은 방법으로 코드를 업데이트 해야 합니다.

  • MongoClient 의 모든 용도를 AsyncMongoClient 로 바꿉니다.

  • 모든 비동기 메서드 호출에 await 키워드를 추가합니다.

  • 함수 내에서 비동기 메서드를 호출하는 경우 함수를 async 으로 표시합니다.

다음 섹션에서는 비동기 API 를 구현 하는 방법을 설명합니다.

비동기식 메서드

다음 표에는 PyMongo 비동기 운전자 에서 사용할 수 있는 비동기 메서드가 나열되어 있습니다. 이러한 메서드를 호출하려면 await 를 입력하고 async 함수 내에서 호출해야 합니다.

클라이언트 메서드

메서드
예시

AsyncMongoClient()

from pymongo import AsyncMongoClient
async with AsyncMongoClient(...)

watch()

async with await client.watch(...) as stream:
   ...

server_info()

await client.server_info(...)

list_databases()

await client.list_databases()

list_database_names()

await client.list_database_names()

drop_database()

await client.drop_database(...)

데이터베이스 메서드

메서드
예시

watch()

async with await db.watch(...) as stream:
   ...

create_collection()

await db.create_collection(...)

aggregate()

async with await client.admin.aggregate(...) as cursor:
   ...

command()

await db.command(...)

cursor_command()

await db.cursor_command(...)

list_collections()

await db.list_collections()

list_collection_names()

await db.list_collection_names()

drop_collection()

await db.drop_collection(...)

validate_collection()

await db.validate_collection(...)

dereference()

await db.dereference(...)

컬렉션 메서드

메서드
예시

watch()

async with await collection.watch(...) as stream:
   ...

insert_one()

await collection.insert_one(...)

insert_many()

await collection.insert_many(...)

replace_one()

await collection.replace_one(...)

update_one()

await collection.update_one(...)

update_many()

await collection.update_many(...)

drop()

await collection.drop()

delete_one()

await collection.delete_one(...)

delete_many()

await collection.delete_many(...)

find_one()

await collection.find_one(...)

estimated_document_count()

await collection.estimated_document_count()

count_documents()

await collection.count_documents(...)

create_index()

await collection.create_index(...)

create_indexes()

await collection.create_indexes(...)

drop_index()

await collection.drop_index(...)

drop_indexes()

await collection.drop_indexes()

list_indexes()

await collection.list_indexes()

index_information()

await collection.index_information()

list_search_indexes()

await collection.list_search_indexes()

create_search_index()

await collection.create_search_index(...)

create_search_indexes()

await collection.create_search_indexes(...)

drop_search_index()

await collection.drop_search_index(...)

update_search_index()

await collection.update_search_index(...)

options()

await collection.options()

aggregate()

async for doc in await collection.aggregate(...):
   ...

aggregate_raw_batches()

async for batch in await collection.aggregate_raw_batches(...):
   ...

rename()

await collection.rename(...)

distinct()

await collection.distinct(...)

find_one_and_delete()

await collection.find_one_and_delete(...)

find_one_and_replace()

await collection.find_one_and_replace(...)

find_one_and_update()

await collection.find_one_and_update(...)

추가 정보

비동기 Python 에 학습 보려면 Python Asyncio 설명서를 참조하세요.

돌아가기

모터 에서 마이그레이션

다음

이전 버전