DatabaseProxy クラス

指定した ID (名前) を使用して新しいコンテナーを作成します。

指定された ID を持つコンテナーが既に存在する場合は、CosmosResourceExistsError が発生します。

async create_container(id: str, partition_key: PartitionKey, **kwargs: Any) -> ContainerProxy

パラメーター

戻り値

新しいコンテナーを表す ContainerProxy インスタンス。

の戻り値の型 :

例外

コンテナーの作成に失敗しました。

例

既定の設定でコンテナーを作成します。

           container_name = "products"
           try:
               container = await database.create_container(
                   id=container_name, partition_key=PartitionKey(path="/productName")
               )
           except exceptions.CosmosResourceExistsError:
               container = database.get_container_client(container_name)

特定の設定を使用してコンテナーを作成します。この場合、カスタム パーティション キー:

           customer_container_name = "customers"
           try:
               customer_container = await database.create_container(
                   id=customer_container_name,
                   partition_key=PartitionKey(path="/city"),
                   default_ttl=200,
               )
           except exceptions.CosmosResourceExistsError:
               customer_container = database.get_container_client(customer_container_name)

コンテナーがまだ存在しない場合は作成します。

コンテナーが既に存在する場合は、既存の設定が返されます。 注: メソッドに渡されたものと異なる場合、既存のコンテナー設定をチェックまたは更新したり、スループットを提供したりすることはありません。

async create_container_if_not_exists(id: str, partition_key: PartitionKey, **kwargs: Any) -> ContainerProxy

パラメーター

戻り値

新しいコンテナーを表す ContainerProxy インスタンス。

の戻り値の型 :

例外

コンテナーの作成に失敗しました。

コンテナーに新しいユーザーを作成します。

既存のユーザーを更新または置換するには、 メソッドを使用します <xref:ContainerProxy.upsert_user> 。

async create_user(body: Dict[str, Any], **kwargs: Any) -> UserProxy

パラメーター

戻り値

新しいユーザーを表す UserProxy インスタンス。

の戻り値の型 :

例外

指定されたユーザーを作成できなかった場合。

例

データベース ユーザーを作成します。

           try:
               await database.create_user(dict(id="Walter Harp"))
               print("Created user Walter Harp.")
           except exceptions.CosmosResourceExistsError:
               print("A user with that ID already exists.")
           except exceptions.CosmosHttpResponseError as failure:
               print("Failed to create user. Status code:{}".format(failure.status_code))

コンテナーを削除します。

async delete_container(container: str | ContainerProxy | Dict[str, Any], **kwargs: Any) -> None

パラメーター

の戻り値の型 :

例外

コンテナーを削除できなかった場合。

指定したユーザーをコンテナーから削除します。

async delete_user(user: str | UserProxy | Dict[str, Any], **kwargs: Any) -> None

パラメーター

の戻り値の型 :

例外

ユーザーが正常に削除されませんでした。

ユーザーがコンテナーに存在しません。

指定した ID (名前) を持つコンテナーの ContainerProxy を取得します。

get_container_client(container: str | ContainerProxy | Dict[str, Any]) -> ContainerProxy

パラメーター

戻り値

コンテナーを表す ContainerProxy インスタンス。

の戻り値の型 :

例外

コンテナーの作成に失敗しました。

例

既存のコンテナーを取得し、発生した場合はエラーを処理します。

           database = client.get_database_client(database_name)
           container = database.get_container_client(container_name)

このデータベースの ThroughputProperties オブジェクトを取得します。

データベースに対して ThroughputProperties が既に存在しない場合は、例外が発生します。

async get_throughput(**kwargs: Any) -> ThroughputProperties

パラメーター

戻り値

データベースの ThroughputProperties。

の戻り値の型 :

例外

データベースのスループット プロパティが存在しないか、スループット プロパティを取得できませんでした。

指定した ID を持つユーザーの UserProxy を取得します。

get_user_client(user: str | UserProxy | Dict[str, Any]) -> UserProxy

パラメーター

戻り値

取得したユーザーを表す UserProxy インスタンス。

の戻り値の型 :

例外

コンテナーの作成に失敗しました。

データベース内のコンテナーを一覧表示します。

list_containers(**kwargs) -> AsyncItemPaged[Dict[str, Any]]

パラメーター

戻り値

コンテナー プロパティ (dicts) の AsyncItemPaged。

の戻り値の型 :

例外

コンテナーの作成に失敗しました。

例

データベース内のすべてのコンテナーを一覧表示します。

           database = client.get_database_client(database_name)
           async for container in database.list_containers():
               print("Container ID: {}".format(container['id']))

コンテナー内のすべてのユーザーを一覧表示します。

list_users(**kwargs: Any) -> AsyncItemPaged[Dict[str, Any]]

パラメーター

戻り値

ユーザー プロパティ (dicts) の AsyncItemPaged。

の戻り値の型 :

例外

コンテナーの作成に失敗しました。

現在のデータベース内のコンテナーのプロパティを一覧表示します。

query_containers(**kwargs: Any) -> AsyncItemPaged[Dict[str, Any]]

パラメーター

戻り値

コンテナー プロパティ (dicts) の AsyncItemPaged。

の戻り値の型 :

例外

コンテナーの作成に失敗しました。

指定されたクエリに一致するすべてのユーザーを返 します。

query_users(query: str | Dict[str, Any], **kwargs: Any) -> AsyncItemPaged[Dict[str, Any]]

パラメーター

戻り値

ユーザー プロパティ (dicts) の AsyncItemPaged。

の戻り値の型 :

例外

コンテナーの作成に失敗しました。

データベースのプロパティを読み取る。

async read(**kwargs: Any) -> Dict[str, Any]

パラメーター

戻り値

データベースのプロパティを表す dict

の戻り値の型 :

例外

指定されたデータベースを取得できなかった場合。

コンテナーのプロパティをリセットします。

プロパティの変更は直ちに永続化されます。 指定されていないプロパティは、既定値にリセットされます。

async replace_container(container: str | ContainerProxy | Dict[str, Any], partition_key: PartitionKey, **kwargs: Any) -> ContainerProxy

パラメーター

戻り値

置換が完了した後のコンテナーを表す ContainerProxy インスタンス。

の戻り値の型 :

例外

コンテナーを置き換えられなかった場合に発生します。 これには、指定された ID を持つコンテナーが存在しない場合が含まれます。

例

コンテナーの TTL プロパティをリセットし、更新されたプロパティを表示します。

           # Set the TTL on the container to 3600 seconds (one hour)
           await database.replace_container(container, partition_key=PartitionKey(path='/productName'), default_ttl=3600)

           # Display the new TTL setting for the container
           container_props = await database.get_container_client(container_name).read()
           print("New container TTL: {}".format(json.dumps(container_props['defaultTtl'])))

データベース レベルのスループットを置き換えます。

データベースに対して ThroughputProperties が既に存在しない場合は、例外が発生します。

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

パラメーター

戻り値

新しいスループットで更新されたデータベースの ThroughputProperties。

の戻り値の型 :

例外

データベースのスループット プロパティが存在しないか、スループット プロパティを更新できませんでした。

指定したユーザーがコンテナーに存在する場合は、それを置き換えます。

async replace_user(user: str | UserProxy | Dict[str, Any], body: Dict[str, Any], **kwargs: Any) -> UserProxy

パラメーター

戻り値

置換後にユーザーを表す UserProxy インスタンスが実行されます。

の戻り値の型 :

例外

置換に失敗した場合、または指定された ID を持つユーザーが存在しない場合。

指定したユーザーを挿入または更新します。

ユーザーがコンテナーに既に存在する場合は、置き換えられます。 ユーザーがまだ存在しない場合は、挿入されます。

async upsert_user(body: Dict[str, Any], **kwargs: Any) -> UserProxy

パラメーター

戻り値

アップサートされたユーザーを表す UserProxy インスタンス。

の戻り値の型 :

例外

指定されたユーザーをアップサートできなかった場合。