ContainerProxy 클래스

  • 참조

특정 DB 컨테이너와 상호 작용하는 인터페이스입니다.

이 클래스는 직접 인스턴스화해서는 안 됩니다. 대신 메서드를 get_container_client 사용하여 기존 컨테이너를 얻거나 메서드를 create_container 사용하여 새 컨테이너를 만듭니다.

Azure Cosmos DB SQL API 데이터베이스의 컨테이너는 문서 컬렉션이며, 각 컨테이너는 항목으로 표시됩니다.

상속
builtins.object
ContainerProxy

생성자

ContainerProxy(client_connection: CosmosClientConnection, database_link: str, id: str, properties: Dict[str, Any] = None)

매개 변수

client_connection
database_link
id
properties
기본값: None

변수

id
str

컨테이너의 ID(이름)

session_token
str

컨테이너에 대한 세션 토큰입니다.

메서드

create_item

컨테이너에 항목을 만듭니다.

기존 항목을 업데이트하거나 바꾸려면 메서드를 upsert_item 사용합니다.
delete_all_items_by_partition_key

파티션 키에 의한 삭제 기능은 Cosmos SDK를 사용하여 동일한 논리적 파티션 키 값을 가진 모든 문서를 삭제할 수 있는 비동기식 백그라운드 작업입니다. 파티션 키별 삭제 작업은 컨테이너에서 사용 가능한 총 RU/s의 최대 10%를 1초마다 사용하도록 제한됩니다. 이렇게 하면 이 백그라운드 작업에서 사용하는 리소스를 제한하는 데 도움이 됩니다.
delete_conflict

컨테이너에서 지정된 충돌을 삭제합니다.

컨테이너에 충돌이 아직 없으면 예외가 발생합니다.
delete_item

컨테이너에서 지정된 항목을 삭제합니다.

컨테이너에 항목이 아직 없는 경우 예외가 발생합니다.
get_conflict

충돌로 식별된 충돌을 가져옵니다.
get_throughput

이 컨테이너에 대한 ThroughputProperties 개체를 가져옵니다.

컨테이너에 대한 ThroughputProperties가 이미 없으면 예외가 발생합니다. :키워드(keyword) Callable response_hook: 응답 메타데이터를 사용하여 호출된 호출 가능한 입니다. :returns: 컨테이너의 처리량입니다. :raises ~azure.cosmos.exceptions.CosmosHttpResponseError: 컨테이너에 대한 처리량 속성이 없거나

처리량 속성을 검색할 수 없습니다.
list_conflicts

컨테이너의 모든 충돌을 나열합니다.
patch_item

임시 메서드 컨테이너에 있는 경우 지정된 항목을 제공된 작업으로 패치합니다.

컨테이너에 항목이 아직 없는 경우 예외가 발생합니다.
query_conflicts

지정된 쿼리와 일치하는 모든 충돌을 반환합니다.
query_items

지정된 쿼리와 일치하는 모든 결과를 반환 합니다.

FROM 절에서 컨테이너 이름에 대한 값을 사용할 수 있지만 컨테이너 이름이 사용되는 경우가 많습니다. 아래 예제에서 컨테이너 이름은 "products"이며 WHERE 절에서 더 쉽게 참조할 수 있는 "p"로 별칭이 지정됩니다.

쿼리 응답의 응답 연속 토큰입니다. 유효한 값은 양의 정수입니다. 값 0은 값을 전달하지 않는 것과 같습니다(기본값 제한 없음). :키워드(keyword) int max_integrated_cache_staleness_in_ms: 통합 캐시의 최대 캐시 부실

밀리초. 세션 또는 최종 일관성을 사용하여 통합 캐시를 사용하도록 구성된 계정의 경우 응답은 이 값보다 부실하지 않습니다.
query_items_change_feed

변경된 항목의 정렬된 목록을 수정된 순서대로 가져옵니다.
read

컨테이너 속성을 읽습니다.
read_all_items

컨테이너의 모든 항목을 나열합니다.
read_item

항목으로 식별된 항목을 가져옵니다.
read_offer

이 컨테이너에 대한 ThroughputProperties 개체를 가져옵니다. 컨테이너에 대한 ThroughputProperties가 이미 없으면 예외가 발생합니다. :키워드(keyword) Callable response_hook: 응답 메타데이터를 사용하여 호출된 호출 가능한 입니다. :returns: 컨테이너의 처리량입니다. :raises ~azure.cosmos.exceptions.CosmosHttpResponseError: 컨테이너에 대한 처리량 속성이 없거나

처리량 속성을 검색할 수 없습니다.
replace_item

컨테이너에 있는 경우 지정된 항목을 바꿉니다.

컨테이너에 항목이 아직 없는 경우 예외가 발생합니다.
replace_throughput

컨테이너의 처리량을 대체합니다.

컨테이너에 대한 ThroughputProperties가 이미 없으면 예외가 발생합니다.
upsert_item

지정된 항목을 삽입하거나 업데이트합니다.

컨테이너에 항목이 이미 있는 경우 해당 항목이 대체됩니다. 항목이 아직 없으면 항목이 삽입됩니다.

create_item

컨테이너에 항목을 만듭니다.

기존 항목을 업데이트하거나 바꾸려면 메서드를 upsert_item 사용합니다.

create_item(body: Dict[str, Any], populate_query_metrics: bool | None = None, pre_trigger_include: str | None = None, post_trigger_include: str | None = None, indexing_directive: Any | None = None, **kwargs: Any) -> Dict[str, Any]

매개 변수

body
필수

만들 항목을 나타내는 dict와 유사한 개체입니다.

pre_trigger_include
필수

사전 작업 트리거로 사용할 트리거 ID입니다.

post_trigger_include
필수

사후 작업 트리거로 사용할 트리거 ID입니다.

indexing_directive
필수

문서를 인덱싱에서 생략해야 하는지 여부를 나타냅니다.

enable_automatic_id_generation
bool

ID가 없는 경우 자동 ID 생성을 사용하도록 설정합니다.

session_token
str

세션 일관성에 사용할 토큰입니다.

initial_headers
dict[str,str]

요청의 일부로 보낼 초기 헤더입니다.

etag
str

ETag 값 또는 와일드카드 문자(*)입니다. 리소스가 변경되었는지 검사 match_condition 매개 변수에 지정된 조건에 따라 작동합니다.

match_condition
MatchConditions

etag에 사용할 일치 조건입니다.

response_hook
Callable

응답 메타데이터를 사용하여 호출된 호출 가능한 입니다.

반환

새 항목을 나타내는 받아쓰기입니다.

반환 형식

dict[str, Any]

예외

CosmosHttpResponseError

지정된 ID가 있는 항목이 이미 있습니다.

delete_all_items_by_partition_key

파티션 키에 의한 삭제 기능은 Cosmos SDK를 사용하여 동일한 논리적 파티션 키 값을 가진 모든 문서를 삭제할 수 있는 비동기식 백그라운드 작업입니다. 파티션 키별 삭제 작업은 컨테이너에서 사용 가능한 총 RU/s의 최대 10%를 1초마다 사용하도록 제한됩니다. 이렇게 하면 이 백그라운드 작업에서 사용하는 리소스를 제한하는 데 도움이 됩니다.

delete_all_items_by_partition_key(partition_key: str | int | float | bool, **kwargs: Any) -> None

매개 변수

partition_key
Any
필수

삭제할 항목의 파티션 키입니다.

pre_trigger_include
str

사전 작업 트리거로 사용할 트리거 ID입니다.

post_trigger_include
str

사후 작업 트리거로 사용할 트리거 ID입니다.

session_token
str

세션 일관성에 사용할 토큰입니다.

etag
str

ETag 값 또는 와일드카드 문자(*)입니다. 리소스가 변경되었는지 검사 match_condition 매개 변수에 지정된 조건에 따라 작동합니다.

match_condition
MatchConditions

etag에 사용할 일치 조건입니다.

response_hook
Callable

응답 메타데이터를 사용하여 호출된 호출 가능한 입니다.

반환 형식

None

예외

CosmosHttpResponseError

지정된 ID가 있는 항목이 이미 있습니다.

delete_conflict

컨테이너에서 지정된 충돌을 삭제합니다.

컨테이너에 충돌이 아직 없으면 예외가 발생합니다.

delete_conflict(conflict: str | Dict[str, Any], partition_key: Any, **kwargs: Any) -> None

매개 변수

conflict
필수

삭제할 충돌을 나타내는 ID(이름) 또는 받아쓰기입니다.

partition_key
필수

삭제할 충돌의 파티션 키입니다.

response_hook
Callable

응답 메타데이터를 사용하여 호출된 호출 가능한 입니다.

반환 형식

None

예외

CosmosHttpResponseError

충돌이 성공적으로 삭제되지 않았습니다.

CosmosResourceNotFoundError

충돌은 컨테이너에 없습니다.

delete_item

컨테이너에서 지정된 항목을 삭제합니다.

컨테이너에 항목이 아직 없는 경우 예외가 발생합니다.

delete_item(item: Dict[str, Any] | str, partition_key: Any, populate_query_metrics: bool | None = None, pre_trigger_include: str | None = None, post_trigger_include: str | None = None, **kwargs: Any) -> None

매개 변수

item
필수

삭제할 항목을 나타내는 ID(이름) 또는 받아쓰기입니다.

partition_key
필수

항목의 파티션 키 값을 지정합니다.

pre_trigger_include
필수

사전 작업 트리거로 사용할 트리거 ID입니다.

post_trigger_include
필수

사후 작업 트리거로 사용할 트리거 ID입니다.

session_token
str

세션 일관성에 사용할 토큰입니다.

initial_headers
dict[str,str]

요청의 일부로 보낼 초기 헤더입니다.

etag
str

ETag 값 또는 와일드카드 문자(*)입니다. 리소스가 변경되었는지 검사 match_condition 매개 변수에 지정된 조건에 따라 작동합니다.

match_condition
MatchConditions

etag에 사용할 일치 조건입니다.

response_hook
Callable

응답 메타데이터를 사용하여 호출된 호출 가능한 입니다.

반환 형식

None

예외

CosmosHttpResponseError

항목이 성공적으로 삭제되지 않았습니다.

CosmosResourceNotFoundError

컨테이너에 항목이 없습니다.

get_conflict

충돌로 식별된 충돌을 가져옵니다.

get_conflict(conflict: str | Dict[str, Any], partition_key: Any, **kwargs: Any) -> Dict[str, Any]

매개 변수

conflict
필수

검색할 충돌을 나타내는 ID(이름) 또는 받아쓰기입니다.

partition_key
필수

검색할 충돌의 파티션 키입니다.

response_hook
Callable

응답 메타데이터를 사용하여 호출된 호출 가능한 입니다.

반환

검색된 충돌을 나타내는 받아쓰기입니다.

반환 형식

dict[str, Any]

예외

CosmosHttpResponseError

지정된 충돌을 검색할 수 없습니다.

get_throughput

이 컨테이너에 대한 ThroughputProperties 개체를 가져옵니다.

컨테이너에 대한 ThroughputProperties가 이미 없으면 예외가 발생합니다. :키워드(keyword) Callable response_hook: 응답 메타데이터를 사용하여 호출된 호출 가능한 입니다. :returns: 컨테이너의 처리량입니다. :raises ~azure.cosmos.exceptions.CosmosHttpResponseError: 컨테이너에 대한 처리량 속성이 없거나

처리량 속성을 검색할 수 없습니다.

get_throughput(**kwargs: Any) -> ThroughputProperties

반환 형식

ThroughputProperties

예외

CosmosHttpResponseError

지정된 ID가 있는 항목이 이미 있습니다.

list_conflicts

컨테이너의 모든 충돌을 나열합니다.

list_conflicts(max_item_count: int | None = None, **kwargs: Any) -> Iterable[Dict[str, Any]]

매개 변수

max_item_count
필수

열거형 작업에서 반환할 최대 항목 수입니다.

response_hook
Callable

응답 메타데이터를 사용하여 호출된 호출 가능한 입니다.

반환

충돌 반복 가능(받아쓰기)입니다.

반환 형식

Iterable[dict[str, Any]]

예외

CosmosHttpResponseError

지정된 ID가 있는 항목이 이미 있습니다.

patch_item

임시 메서드 컨테이너에 있는 경우 지정된 항목을 제공된 작업으로 패치합니다.

컨테이너에 항목이 아직 없는 경우 예외가 발생합니다.

patch_item(item: str | Dict[str, Any], partition_key: str | int | float | bool, patch_operations: List[Dict[str, Any]], **kwargs: Any) -> Dict[str, Any]

매개 변수

item
Union[str, Dict[str, Any]]
필수

패치할 항목을 나타내는 ID(이름) 또는 받아쓰기입니다.

partition_key
Union[str, int, float, bool]
필수

패치할 개체의 파티션 키입니다.

patch_operations
List[Dict[str, Any]]
필수

항목에 적용할 패치 작업 목록입니다.

filter_predicate
str

패치 작업에 적용할 조건부 필터입니다.

pre_trigger_include
str

사전 작업 트리거로 사용할 트리거 ID입니다.

post_trigger_include
str

사후 작업 트리거로 사용할 트리거 ID입니다.

session_token
str

세션 일관성에 사용할 토큰입니다.

etag
str

ETag 값 또는 와일드카드 문자(*)입니다. 리소스가 변경되었는지 검사 match_condition 매개 변수에 지정된 조건에 따라 작동합니다.

match_condition
MatchConditions

etag에 사용할 일치 조건입니다.

response_hook
Callable

응답 메타데이터를 사용하여 호출된 호출 가능한 입니다.

반환

패치 작업을 수행한 후 항목을 나타내는 받아쓰기입니다.

반환 형식

dict[str, Any]

예외

CosmosHttpResponseError

패치 작업이 실패했거나 ID가 지정된 항목이 없습니다.

query_conflicts

지정된 쿼리와 일치하는 모든 충돌을 반환합니다.

query_conflicts(query: str, parameters: List[str] | None = None, enable_cross_partition_query: bool | None = None, partition_key: Any | None = None, max_item_count: int | None = None, **kwargs: Any) -> Iterable[Dict[str, Any]]

매개 변수

query
필수

실행할 Azure Cosmos DB SQL 쿼리입니다.

parameters
필수

쿼리에 대한 매개 변수의 선택적 배열입니다. 쿼리가 제공되지 않으면 무시됩니다.

enable_cross_partition_query
필수

둘 이상의 요청을 전송하여 Azure Cosmos DB 서비스에서 쿼리를 실행할 수 있습니다. 쿼리 범위가 단일 파티션 키 값으로 지정되지 않은 경우 둘 이상의 요청이 필요합니다.

partition_key
필수

항목의 파티션 키 값을 지정합니다.

max_item_count
필수

열거형 작업에서 반환할 최대 항목 수입니다.

response_hook
Callable

응답 메타데이터를 사용하여 호출된 호출 가능한 입니다.

반환

충돌 반복 가능(받아쓰기)입니다.

반환 형식

Iterable[dict[str, Any]]

예외

CosmosHttpResponseError

지정된 ID가 있는 항목이 이미 있습니다.

query_items

지정된 쿼리와 일치하는 모든 결과를 반환 합니다.

FROM 절에서 컨테이너 이름에 대한 값을 사용할 수 있지만 컨테이너 이름이 사용되는 경우가 많습니다. 아래 예제에서 컨테이너 이름은 "products"이며 WHERE 절에서 더 쉽게 참조할 수 있는 "p"로 별칭이 지정됩니다.

쿼리 응답의 응답 연속 토큰입니다. 유효한 값은 양의 정수입니다. 값 0은 값을 전달하지 않는 것과 같습니다(기본값 제한 없음). :키워드(keyword) int max_integrated_cache_staleness_in_ms: 통합 캐시의 최대 캐시 부실

밀리초. 세션 또는 최종 일관성을 사용하여 통합 캐시를 사용하도록 구성된 계정의 경우 응답은 이 값보다 부실하지 않습니다.

query_items(query: str, parameters: List[Dict[str, object]] | None = None, partition_key: Any | None = None, enable_cross_partition_query: bool | None = None, max_item_count: int | None = None, enable_scan_in_query: bool | None = None, populate_query_metrics: bool | None = None, **kwargs: Any) -> Iterable[Dict[str, Any]]

반환

항목의 반복 가능(받아쓰기)입니다.

반환 형식

<xref:ItemPaged>[Dict[str, Any]]

예외

CosmosHttpResponseError

지정된 ID가 있는 항목이 이미 있습니다.

예제

중단되지 않은 모든 제품을 가져옵니다.


   import json

   for item in container.query_items(
       query='SELECT * FROM products p WHERE p.productModel <> "DISCONTINUED"',
       enable_cross_partition_query=True,
   ):
       print(json.dumps(item, indent=True))

중단된 모든 제품을 가져오는 매개 변수가 있는 쿼리:


   discontinued_items = container.query_items(
       query='SELECT * FROM products p WHERE p.productModel = @model AND p.productName="Widget"',
       parameters=[dict(name="@model", value="DISCONTINUED")],
   )
   for item in discontinued_items:
       print(json.dumps(item, indent=True))

query_items_change_feed

변경된 항목의 정렬된 목록을 수정된 순서대로 가져옵니다.

query_items_change_feed(partition_key_range_id: str | None = None, is_start_from_beginning: bool = False, continuation: str | None = None, max_item_count: int | None = None, **kwargs: Any) -> Iterable[Dict[str, Any]]

매개 변수

partition_key_range_id
필수

ChangeFeed 요청은 특정 파티션 키 범위에 대해 실행할 수 있습니다. 이는 여러 소비자 간에 변경 피드를 병렬로 처리하는 데 사용됩니다.

partition_key
필수

ChangeFeed 요청이 대상으로 지정되는 파티션 키입니다.

is_start_from_beginning
필수

변경 피드가 시작(true) 또는 현재(false)에서 시작해야 하는지 여부를 가져옵니다. 기본적으로 현재(false)에서 시작됩니다.

continuation
필수

변경 피드를 읽기 위한 연속으로 사용할 e_tag 값입니다.

max_item_count
필수

열거형 작업에서 반환할 최대 항목 수입니다.

response_hook
Callable

응답 메타데이터를 사용하여 호출된 호출 가능한 입니다.

반환

항목의 반복 가능(받아쓰기)입니다.

반환 형식

Iterable[dict[str, Any]]

예외

CosmosHttpResponseError

지정된 ID가 있는 항목이 이미 있습니다.

read

컨테이너 속성을 읽습니다.

read(*, populate_partition_key_range_statistics: bool | None = None, populate_quota_info: bool | None = None, **kwargs)

매개 변수

populate_partition_key_range_statistics
bool

응답 헤더에서 파티션 키 범위 통계 반환을 사용하도록 설정합니다.

populate_quota_info
bool

응답 헤더에서 컬렉션 스토리지 할당량 정보를 반환하도록 설정합니다.

session_token
str

세션 일관성에 사용할 토큰입니다.

initial_headers
dict[str,str]

요청의 일부로 보낼 초기 헤더입니다.

response_hook
Callable

응답 메타데이터를 사용하여 호출된 호출 가능한 입니다.

반환

검색된 컨테이너를 나타내는 Dict입니다.

반환 형식

dict[str, Any]

예외

CosmosHttpResponseError

컨테이너를 검색할 수 없는 경우 발생합니다. 여기에는 컨테이너가 없는 경우도 포함됩니다.

read_all_items

컨테이너의 모든 항목을 나열합니다.

read_all_items(max_item_count: int | None = None, populate_query_metrics: bool | None = None, **kwargs: Any) -> Iterable[Dict[str, Any]]

매개 변수

max_item_count
필수

열거형 작업에서 반환할 최대 항목 수입니다.

session_token
str

세션 일관성에 사용할 토큰입니다.

initial_headers
dict[str,str]

요청의 일부로 보낼 초기 헤더입니다.

response_hook
Callable

응답 메타데이터를 사용하여 호출된 호출 가능한 입니다.

max_integrated_cache_staleness_in_ms
int

통합 캐시의 최대 캐시 부실(밀리초)입니다. 세션 또는 최종 일관성을 사용하여 통합 캐시를 사용하도록 구성된 계정의 경우 응답은 이 값보다 부실하지 않습니다.

반환

항목의 반복 가능(받아쓰기)입니다.

반환 형식

Iterable[dict[str, Any]]

예외

CosmosHttpResponseError

지정된 ID가 있는 항목이 이미 있습니다.

read_item

항목으로 식별된 항목을 가져옵니다.

read_item(item: str | Dict[str, Any], partition_key: Any, populate_query_metrics: bool | None = None, post_trigger_include: str | None = None, **kwargs: Any) -> Dict[str, Any]

매개 변수

item
필수

검색할 항목을 나타내는 ID(이름) 또는 받아쓰기입니다.

partition_key
필수

검색할 항목의 파티션 키입니다.

post_trigger_include
필수

사후 작업 트리거로 사용할 트리거 ID입니다.

session_token
str

세션 일관성에 사용할 토큰입니다.

initial_headers
dict[str,str]

요청의 일부로 보낼 초기 헤더입니다.

response_hook
Callable

응답 메타데이터를 사용하여 호출된 호출 가능한 입니다.

max_integrated_cache_staleness_in_ms
int

통합 캐시의 최대 캐시 부실(밀리초)입니다. 세션 또는 최종 일관성을 사용하여 통합 캐시를 사용하도록 구성된 계정의 경우 응답은 이 값보다 부실하지 않습니다.

반환

검색할 항목을 나타내는 Dict입니다.

반환 형식

dict[str, Any]

예외

CosmosHttpResponseError

지정된 항목을 검색할 수 없습니다.

예제

데이터베이스에서 항목을 가져와 해당 속성 중 하나를 업데이트합니다.


   item = container.read_item("item2", partition_key="Widget")
   item["productModel"] = "DISCONTINUED"
   updated_item = container.upsert_item(item)

read_offer

이 컨테이너에 대한 ThroughputProperties 개체를 가져옵니다. 컨테이너에 대한 ThroughputProperties가 이미 없으면 예외가 발생합니다. :키워드(keyword) Callable response_hook: 응답 메타데이터를 사용하여 호출된 호출 가능한 입니다. :returns: 컨테이너의 처리량입니다. :raises ~azure.cosmos.exceptions.CosmosHttpResponseError: 컨테이너에 대한 처리량 속성이 없거나

처리량 속성을 검색할 수 없습니다.

read_offer(**kwargs: Any) -> Offer

반환 형식

ThroughputProperties

예외

CosmosHttpResponseError

지정된 ID가 있는 항목이 이미 있습니다.

replace_item

컨테이너에 있는 경우 지정된 항목을 바꿉니다.

컨테이너에 항목이 아직 없는 경우 예외가 발생합니다.

replace_item(item: str | Dict[str, Any], body: Dict[str, Any], populate_query_metrics: bool | None = None, pre_trigger_include: str | None = None, post_trigger_include: str | None = None, **kwargs: Any) -> Dict[str, Any]

매개 변수

item
필수

바꿀 항목을 나타내는 ID(이름) 또는 받아쓰기입니다.

body
필수

바꿀 항목을 나타내는 dict와 유사한 개체입니다.

pre_trigger_include
필수

사전 작업 트리거로 사용할 트리거 ID입니다.

post_trigger_include
필수

사후 작업 트리거로 사용할 트리거 ID입니다.

session_token
str

세션 일관성에 사용할 토큰입니다.

initial_headers
dict[str,str]

요청의 일부로 보낼 초기 헤더입니다.

etag
str

ETag 값 또는 와일드카드 문자(*)입니다. 리소스가 변경되었는지 검사 match_condition 매개 변수에 지정된 조건에 따라 작동합니다.

match_condition
MatchConditions

etag에 사용할 일치 조건입니다.

response_hook
Callable

응답 메타데이터를 사용하여 호출된 호출 가능한 입니다.

반환

바꾸기를 통과한 후 항목을 나타내는 받아쓰기입니다.

반환 형식

dict[str, Any]

예외

CosmosHttpResponseError

바꾸기에 실패했거나 지정된 ID가 있는 항목이 없습니다.

replace_throughput

컨테이너의 처리량을 대체합니다.

컨테이너에 대한 ThroughputProperties가 이미 없으면 예외가 발생합니다.

replace_throughput(throughput: int | ThroughputProperties | None, **kwargs: Any) -> ThroughputProperties

매개 변수

throughput
필수

설정할 처리량(정수)입니다.

response_hook
Callable

응답 메타데이터를 사용하여 호출된 호출 가능한 입니다.

반환

새 처리량으로 업데이트된 컨테이너에 대한 처리량속성입니다.

반환 형식

ThroughputProperties

예외

CosmosHttpResponseError

컨테이너에 대한 처리량 속성이 없거나 처리량 속성을 업데이트할 수 없습니다.

upsert_item

지정된 항목을 삽입하거나 업데이트합니다.

컨테이너에 항목이 이미 있는 경우 해당 항목이 대체됩니다. 항목이 아직 없으면 항목이 삽입됩니다.

upsert_item(body: Dict[str, Any], populate_query_metrics: bool | None = None, pre_trigger_include: str | None = None, post_trigger_include: str | None = None, **kwargs: Any) -> Dict[str, Any]

매개 변수

body
필수

업데이트하거나 삽입할 항목을 나타내는 dict와 유사한 개체입니다.

pre_trigger_include
필수

사전 작업 트리거로 사용할 트리거 ID입니다.

post_trigger_include
필수

사후 작업 트리거로 사용할 트리거 ID입니다.

session_token
str

세션 일관성에 사용할 토큰입니다.

initial_headers
dict[str,str]

요청의 일부로 보낼 초기 헤더입니다.

etag
str

ETag 값 또는 와일드카드 문자(*)입니다. 리소스가 변경되었는지 검사 match_condition 매개 변수에 지정된 조건에 따라 작동합니다.

match_condition
MatchConditions

etag에 사용할 일치 조건입니다.

response_hook
Callable

응답 메타데이터를 사용하여 호출된 호출 가능한 입니다.

반환

upserted 항목을 나타내는 받아쓰기입니다.

반환 형식

dict[str, Any]

예외

CosmosHttpResponseError

지정된 항목을 업서트할 수 없습니다.

특성

is_system_key

scripts