你当前正在访问 Microsoft Azure Global Edition 技术文档网站。如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站，请访问 https://docs.azure.cn。

Cassandra Resources - Create Update Cassandra Table

参考

Service:: Cosmos DB Resource Provider

API Version:: 2023-11-15

创建或更新 Azure Cosmos DB Cassandra 表

PUT https://management.azure.com/subscriptions/{subscriptionId}/resourceGroups/{resourceGroupName}/providers/Microsoft.DocumentDB/databaseAccounts/{accountName}/cassandraKeyspaces/{keyspaceName}/tables/{tableName}?api-version=2023-11-15

URI 参数

名称	在	必需	类型	说明
accountName	path	True	string	Cosmos DB 数据库帐户名称。 Regex pattern: `^[a-z0-9]+(-[a-z0-9]+)*`
keyspaceName	path	True	string	Cosmos DB 密钥空间名称。
resourceGroupName	path	True	string	资源组的名称。此名称不区分大小写。
subscriptionId	path	True	string	目标订阅的 ID。
tableName	path	True	string	Cosmos DB 表名称。
api-version	query	True	string	要用于此操作的 API 版本。

请求正文

名称	必需	类型	说明
properties.resource	True	CassandraTableResource	Cassandra 表的标准 JSON 格式
location		string	资源所属的资源组的位置。
properties.options		CreateUpdateOptions	要应用于请求的选项的键值对。这对应于随请求一起发送的标头。
tags		object	标记是描述资源的键值对的列表。在查看此资源和为此资源分组（跨资源组）时，可以使用这些标记。最多可以为资源提供 15 个标记。每个标记的键不能超过 128 个字符，值不能超过 256 个字符。例如，模板类型的默认体验设置为“defaultExperience”：“Cassandra”。当前的“defaultExperience”值还包括“Table”、“Graph”、“DocumentDB”和“MongoDB”。

响应

名称	类型	说明
200 OK	CassandraTableGetResults	Cassandra 表创建或更新操作已成功完成。
202 Accepted		Cassandra 表创建或更新操作将以异步方式完成。 Headers azure-AsyncOperation: string location: string

名称

类型

说明

200 OK

CassandraTableGetResults

Cassandra 表创建或更新操作已成功完成。

202 Accepted

Cassandra 表创建或更新操作将以异步方式完成。

Headers

azure-AsyncOperation: string
location: string

安全性

azure_auth

Azure Active Directory OAuth2 流

Type: oauth2
Flow: implicit
Authorization URL: https://login.microsoftonline.com/common/oauth2/authorize

Scopes

名称	说明
user_impersonation	模拟用户帐户

示例

CosmosDBCassandraTableCreateUpdate

Sample Request

PUT https://management.azure.com/subscriptions/subid/resourceGroups/rg1/providers/Microsoft.DocumentDB/databaseAccounts/ddb1/cassandraKeyspaces/keyspaceName/tables/tableName?api-version=2023-11-15

{
  "location": "West US",
  "tags": {},
  "properties": {
    "resource": {
      "id": "tableName",
      "defaultTtl": 100,
      "schema": {
        "columns": [
          {
            "name": "columnA",
            "type": "Ascii"
          }
        ],
        "partitionKeys": [
          {
            "name": "columnA"
          }
        ],
        "clusterKeys": [
          {
            "name": "columnA",
            "orderBy": "Asc"
          }
        ]
      }
    },
    "options": {}
  }
}


import com.azure.resourcemanager.cosmos.models.CassandraPartitionKey;
import com.azure.resourcemanager.cosmos.models.CassandraSchema;
import com.azure.resourcemanager.cosmos.models.CassandraTableCreateUpdateParameters;
import com.azure.resourcemanager.cosmos.models.CassandraTableResource;
import com.azure.resourcemanager.cosmos.models.ClusterKey;
import com.azure.resourcemanager.cosmos.models.Column;
import com.azure.resourcemanager.cosmos.models.CreateUpdateOptions;
import java.util.Arrays;
import java.util.HashMap;
import java.util.Map;

/**
 * Samples for CassandraResources CreateUpdateCassandraTable.
 */
public final class Main {
    /*
     * x-ms-original-file: specification/cosmos-db/resource-manager/Microsoft.DocumentDB/stable/2023-11-15/examples/
     * CosmosDBCassandraTableCreateUpdate.json
     */
    /**
     * Sample code: CosmosDBCassandraTableCreateUpdate.
     * 
     * @param azure The entry point for accessing resource management APIs in Azure.
     */
    public static void cosmosDBCassandraTableCreateUpdate(com.azure.resourcemanager.AzureResourceManager azure) {
        azure.cosmosDBAccounts().manager().serviceClient().getCassandraResources().createUpdateCassandraTable("rg1",
            "ddb1", "keyspaceName", "tableName",
            new CassandraTableCreateUpdateParameters().withLocation("West US").withTags(mapOf())
                .withResource(new CassandraTableResource().withId("tableName").withDefaultTtl(100)
                    .withSchema(new CassandraSchema()
                        .withColumns(Arrays.asList(new Column().withName("columnA").withType("Ascii")))
                        .withPartitionKeys(Arrays.asList(new CassandraPartitionKey().withName("columnA")))
                        .withClusterKeys(Arrays.asList(new ClusterKey().withName("columnA").withOrderBy("Asc")))))
                .withOptions(new CreateUpdateOptions()),
            com.azure.core.util.Context.NONE);
    }

    // Use "Map.of" if available
    @SuppressWarnings("unchecked")
    private static <T> Map<String, T> mapOf(Object... inputs) {
        Map<String, T> map = new HashMap<>();
        for (int i = 0; i < inputs.length; i += 2) {
            String key = (String) inputs[i];
            T value = (T) inputs[i + 1];
            map.put(key, value);
        }
        return map;
    }
}

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

from azure.identity import DefaultAzureCredential
from azure.mgmt.cosmosdb import CosmosDBManagementClient

"""
# PREREQUISITES
    pip install azure-identity
    pip install azure-mgmt-cosmosdb
# USAGE
    python cosmos_db_cassandra_table_create_update.py

    Before run the sample, please set the values of the client ID, tenant ID and client secret
    of the AAD application as environment variables: AZURE_CLIENT_ID, AZURE_TENANT_ID,
    AZURE_CLIENT_SECRET. For more info about how to get the value, please see:
    https://docs.microsoft.com/azure/active-directory/develop/howto-create-service-principal-portal
"""


def main():
    client = CosmosDBManagementClient(
        credential=DefaultAzureCredential(),
        subscription_id="subid",
    )

    response = client.cassandra_resources.begin_create_update_cassandra_table(
        resource_group_name="rg1",
        account_name="ddb1",
        keyspace_name="keyspaceName",
        table_name="tableName",
        create_update_cassandra_table_parameters={
            "location": "West US",
            "properties": {
                "options": {},
                "resource": {
                    "defaultTtl": 100,
                    "id": "tableName",
                    "schema": {
                        "clusterKeys": [{"name": "columnA", "orderBy": "Asc"}],
                        "columns": [{"name": "columnA", "type": "Ascii"}],
                        "partitionKeys": [{"name": "columnA"}],
                    },
                },
            },
            "tags": {},
        },
    ).result()
    print(response)


# x-ms-original-file: specification/cosmos-db/resource-manager/Microsoft.DocumentDB/stable/2023-11-15/examples/CosmosDBCassandraTableCreateUpdate.json
if __name__ == "__main__":
    main()

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

package armcosmos_test

import (
	"context"
	"log"

	"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
	"github.com/Azure/azure-sdk-for-go/sdk/azidentity"
	"github.com/Azure/azure-sdk-for-go/sdk/resourcemanager/cosmos/armcosmos/v2"
)

// Generated from example definition: https://github.com/Azure/azure-rest-api-specs/blob/41e4538ed7bb3ceac3c1322c9455a0812ed110ac/specification/cosmos-db/resource-manager/Microsoft.DocumentDB/stable/2023-11-15/examples/CosmosDBCassandraTableCreateUpdate.json
func ExampleCassandraResourcesClient_BeginCreateUpdateCassandraTable() {
	cred, err := azidentity.NewDefaultAzureCredential(nil)
	if err != nil {
		log.Fatalf("failed to obtain a credential: %v", err)
	}
	ctx := context.Background()
	clientFactory, err := armcosmos.NewClientFactory("<subscription-id>", cred, nil)
	if err != nil {
		log.Fatalf("failed to create client: %v", err)
	}
	poller, err := clientFactory.NewCassandraResourcesClient().BeginCreateUpdateCassandraTable(ctx, "rg1", "ddb1", "keyspaceName", "tableName", armcosmos.CassandraTableCreateUpdateParameters{
		Location: to.Ptr("West US"),
		Tags:     map[string]*string{},
		Properties: &armcosmos.CassandraTableCreateUpdateProperties{
			Options: &armcosmos.CreateUpdateOptions{},
			Resource: &armcosmos.CassandraTableResource{
				Schema: &armcosmos.CassandraSchema{
					ClusterKeys: []*armcosmos.ClusterKey{
						{
							Name:    to.Ptr("columnA"),
							OrderBy: to.Ptr("Asc"),
						}},
					Columns: []*armcosmos.Column{
						{
							Name: to.Ptr("columnA"),
							Type: to.Ptr("Ascii"),
						}},
					PartitionKeys: []*armcosmos.CassandraPartitionKey{
						{
							Name: to.Ptr("columnA"),
						}},
				},
				DefaultTTL: to.Ptr[int32](100),
				ID:         to.Ptr("tableName"),
			},
		},
	}, nil)
	if err != nil {
		log.Fatalf("failed to finish the request: %v", err)
	}
	res, err := poller.PollUntilDone(ctx, nil)
	if err != nil {
		log.Fatalf("failed to pull the result: %v", err)
	}
	// You could use response here. We use blank identifier for just demo purposes.
	_ = res
	// If the HTTP response code is 200 as defined in example definition, your response structure would look as follows. Please pay attention that all the values in the output are fake values for just demo purposes.
	// res.CassandraTableGetResults = armcosmos.CassandraTableGetResults{
	// 	Name: to.Ptr("tableName"),
	// 	Type: to.Ptr("Microsoft.DocumentDB/databaseAccounts/cassandraKeyspaces/cassandraTables"),
	// 	ID: to.Ptr("/subscriptions/subid/resourceGroups/rg1/providers/Microsoft.DocumentDB/databaseAccounts/ddb1/cassandraKeyspaces/keyspaceName/cassandraTables/tableName"),
	// 	Location: to.Ptr("West US"),
	// 	Tags: map[string]*string{
	// 	},
	// 	Properties: &armcosmos.CassandraTableGetProperties{
	// 		Resource: &armcosmos.CassandraTableGetPropertiesResource{
	// 			Schema: &armcosmos.CassandraSchema{
	// 				ClusterKeys: []*armcosmos.ClusterKey{
	// 					{
	// 						Name: to.Ptr("columnA"),
	// 						OrderBy: to.Ptr("Asc"),
	// 				}},
	// 				Columns: []*armcosmos.Column{
	// 					{
	// 						Name: to.Ptr("columnA"),
	// 						Type: to.Ptr("Ascii"),
	// 				}},
	// 				PartitionKeys: []*armcosmos.CassandraPartitionKey{
	// 					{
	// 						Name: to.Ptr("columnA"),
	// 				}},
	// 			},
	// 			DefaultTTL: to.Ptr[int32](100),
	// 			ID: to.Ptr("tableName"),
	// 		},
	// 	},
	// }
}

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

const { CosmosDBManagementClient } = require("@azure/arm-cosmosdb");
const { DefaultAzureCredential } = require("@azure/identity");

/**
 * This sample demonstrates how to Create or update an Azure Cosmos DB Cassandra Table
 *
 * @summary Create or update an Azure Cosmos DB Cassandra Table
 * x-ms-original-file: specification/cosmos-db/resource-manager/Microsoft.DocumentDB/stable/2023-11-15/examples/CosmosDBCassandraTableCreateUpdate.json
 */
async function cosmosDbCassandraTableCreateUpdate() {
  const subscriptionId = process.env["COSMOSDB_SUBSCRIPTION_ID"] || "subid";
  const resourceGroupName = process.env["COSMOSDB_RESOURCE_GROUP"] || "rg1";
  const accountName = "ddb1";
  const keyspaceName = "keyspaceName";
  const tableName = "tableName";
  const createUpdateCassandraTableParameters = {
    location: "West US",
    options: {},
    resource: {
      schema: {
        clusterKeys: [{ name: "columnA", orderBy: "Asc" }],
        columns: [{ name: "columnA", type: "Ascii" }],
        partitionKeys: [{ name: "columnA" }],
      },
      defaultTtl: 100,
      id: "tableName",
    },
    tags: {},
  };
  const credential = new DefaultAzureCredential();
  const client = new CosmosDBManagementClient(credential, subscriptionId);
  const result = await client.cassandraResources.beginCreateUpdateCassandraTableAndWait(
    resourceGroupName,
    accountName,
    keyspaceName,
    tableName,
    createUpdateCassandraTableParameters,
  );
  console.log(result);
}

To use the Azure SDK library in your project, see this documentation. To provide feedback on this code sample, open a GitHub issue

Sample Response

Status code:: 200

{
  "id": "/subscriptions/subid/resourceGroups/rg1/providers/Microsoft.DocumentDB/databaseAccounts/ddb1/cassandraKeyspaces/keyspaceName/cassandraTables/tableName",
  "name": "tableName",
  "type": "Microsoft.DocumentDB/databaseAccounts/cassandraKeyspaces/cassandraTables",
  "location": "West US",
  "tags": {},
  "properties": {
    "resource": {
      "id": "tableName",
      "defaultTtl": 100,
      "schema": {
        "columns": [
          {
            "name": "columnA",
            "type": "Ascii"
          }
        ],
        "partitionKeys": [
          {
            "name": "columnA"
          }
        ],
        "clusterKeys": [
          {
            "name": "columnA",
            "orderBy": "Asc"
          }
        ]
      }
    }
  }
}

Status code:: 202

定义

名称	说明
AutoscaleSettings
CassandraPartitionKey	Cosmos DB Cassandra 表分区键
CassandraSchema	Cosmos DB Cassandra 表架构
CassandraTableCreateUpdateParameters	用于创建和更新 Cosmos DB Cassandra 表的参数。
CassandraTableGetResults	Azure Cosmos DB Cassandra 表。
CassandraTableResource	Cosmos DB Cassandra 表资源对象
ClusterKey	Cosmos DB Cassandra 表群集密钥
Column	Cosmos DB Cassandra 表列
CreateUpdateOptions	CreateUpdateOptions 是描述资源的键值对的列表。支持的密钥为“If-Match”、“If-None-Match”、“Session-Token”和“Throughput”
Options
Resource

AutoscaleSettings

名称	类型	说明
maxThroughput	integer	表示资源可以纵向扩展到的最大吞吐量。

CassandraPartitionKey

Cosmos DB Cassandra 表分区键

名称	类型	说明
name	string	Cosmos DB Cassandra 表分区键的名称

CassandraSchema

Cosmos DB Cassandra 表架构

名称	类型	说明
clusterKeys	ClusterKey[]	群集密钥列表。
columns	Column[]	Cassandra 表列的列表。
partitionKeys	CassandraPartitionKey[]	分区键列表。

CassandraTableCreateUpdateParameters

用于创建和更新 Cosmos DB Cassandra 表的参数。

名称	类型	说明
id	string	ARM 资源的唯一资源标识符。
location	string	资源所属的资源组的位置。
name	string	ARM 资源的名称。
properties.options	CreateUpdateOptions	要应用于请求的选项的键值对。这对应于随请求一起发送的标头。
properties.resource	CassandraTableResource	Cassandra 表的标准 JSON 格式
tags	object	标记是描述资源的键值对的列表。在查看此资源和为此资源分组（跨资源组）时，可以使用这些标记。最多可以为资源提供 15 个标记。每个标记的键不能超过 128 个字符，值不能超过 256 个字符。例如，模板类型的默认体验设置为“defaultExperience”：“Cassandra”。当前的“defaultExperience”值还包括“Table”、“Graph”、“DocumentDB”和“MongoDB”。
type	string	Azure 资源的类型。

CassandraTableGetResults

Azure Cosmos DB Cassandra 表。

名称	类型	说明
id	string	ARM 资源的唯一资源标识符。
location	string	资源所属的资源组的位置。
name	string	ARM 资源的名称。
properties.options	Options
properties.resource	Resource
tags	object	标记是描述资源的键值对的列表。在查看此资源和为此资源分组（跨资源组）时，可以使用这些标记。最多可以为资源提供 15 个标记。每个标记的键不能超过 128 个字符，值不能超过 256 个字符。例如，模板类型的默认体验设置为“defaultExperience”：“Cassandra”。当前的“defaultExperience”值还包括“Table”、“Graph”、“DocumentDB”和“MongoDB”。
type	string	Azure 资源的类型。

CassandraTableResource

Cosmos DB Cassandra 表资源对象

名称	类型	说明
analyticalStorageTtl	integer	分析 TTL。
defaultTtl	integer	Cosmos DB Cassandra 表的生存时间
id	string	Cosmos DB Cassandra 表的名称
schema	CassandraSchema	Cosmos DB Cassandra 表的架构

ClusterKey

Cosmos DB Cassandra 表群集密钥

名称	类型	说明
name	string	Cosmos DB Cassandra 表群集键的名称
orderBy	string	Cosmos DB Cassandra 表群集密钥的顺序，仅支持“Asc”和“Desc”

Column

Cosmos DB Cassandra 表列

名称	类型	说明
name	string	Cosmos DB Cassandra 表列的名称
type	string	Cosmos DB Cassandra 表列的类型

CreateUpdateOptions

CreateUpdateOptions 是描述资源的键值对的列表。支持的密钥为“If-Match”、“If-None-Match”、“Session-Token”和“Throughput”

名称	类型	说明
autoscaleSettings	AutoscaleSettings	指定自动缩放设置。注意：需要吞吐量或 autoscaleSettings，但不能同时满足这两项要求。
throughput	integer	每秒请求单位数。例如，“throughput”：10000。

Options

名称	类型	说明
autoscaleSettings	AutoscaleSettings	指定自动缩放设置。
throughput	integer	Cosmos DB 资源吞吐量或 autoscaleSettings 的值。检索产品/服务详细信息时，请使用 ThroughputSetting 资源。

Resource

名称	类型	说明
_etag	string	系统生成的属性，表示乐观并发控制所需的资源 etag。
_rid	string	系统生成的属性。唯一标识符。
_ts	number	系统生成的属性，表示资源的上次更新时间戳。
analyticalStorageTtl	integer	分析 TTL。
defaultTtl	integer	Cosmos DB Cassandra 表的生存时间
id	string	Cosmos DB Cassandra 表的名称
schema	CassandraSchema	Cosmos DB Cassandra 表的架构

Cassandra Resources - Create Update Cassandra Table

URI 参数

请求正文

响应

安全性

azure_auth

Scopes

示例

CosmosDBCassandraTableCreateUpdate

Sample Request

Sample Response

定义

AutoscaleSettings

CassandraPartitionKey

CassandraSchema

CassandraTableCreateUpdateParameters

CassandraTableGetResults

CassandraTableResource

ClusterKey

Column

CreateUpdateOptions

Options

Resource

其他资源