1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 298 299 300 301 302 303 304 305 306 307 308 309 310 311 312 313 314 315 316 317 318 319 320 321 322 323 324 325 326 327 328 329 330 331 332 333 334 335 336 337 338 339 340 341 342 343 344 345 346 347 348 349 350 351 352 353 354 355 356 357 358 359 360 361 362 363 364 365 366 367 368 369 370 371 372 373 374 375 376 377 378 379 380 381 382 383 384 385 386 387 388 389 390 391 392 393 394 395 396 397 398 399 400 401 402 403 404 405 406 407 408 409 410 411 412 413 414 415 416 417 418 419 420 421 422 423 424 425 426 427 428 429 430 431 432 433 434 435 436 437 438 439 440 441 442 443 444 445 446 447 448 449 450 451 452 453 454 455 456 457 458 459 460 461 462 463 464 465 466 467 468 469 470 471 472 473 474 475 476 477 478 479 480 481 482 483 484 485 486 487 488 489 490 491 492 493 494 495 496 497 498 499 500 501 502 503 504 505 506 507 508 509 510 511 512 513 514 515 516 517 518 519 520 521 522 523 524 525 526 527 528 529 530 531 532 533 534 535 536 537 538 539 540 541 542 543 544 545 546 547 548 549 550 551 552 553 554 555 556 557 558 559 560 561 562 563 564 565 566 567 568 569 570 571 572 573 574 575 576 577 578 579 580 581 582 583 584 585 586 587 588 589 590 591 592 593 594 595 596 597 598 599 600 601 602 603 604 605 606 607 608 609 610 611 612 613 614 615 616 617 618 619 620 621 622 623 624 625 626 627 628 629 630 631 632 633 634 635 636 637 638 639 640 641 642 643 644 645 646 647 648 649 650 651 652 653 654 655 656 657 658 659 660 661 662 663 664 665 666 667 668 669 670 671 672 673 674 675 676 677 678 679 680 681 682 683 684 685 686 687 688 689 690 691 692 693 694 695 696 697 698 699 700 701 702 703 704 705 706 707 708 709 710 711 712 713 714 715 716 717 718 719 720 721 722 723 724 725 726 727 728 729 730 731 732 733 734 735 736 737 738 739 740 741 742 743 744 745 746 747 748 749 750 751 752 753 754 755 756 757 758 759 760 761 762 763 764 765 766 767 768 769 770 771 772 773 774 775 776 777 778 779 780 781 782 783 784 785 786 787 788 789 790 791 792 793 794 795 796 797 798 799 800 801 802 803 804 805 806 807 808 809 810 811 812 813 814 815 816 817 818 819 820 821 822 823 824 825 826 827 828 829 830 831 832 833 834 835 836 837 838 839 840 841 842 843 844 845 846 847 848 849 850 851 852 853 854 855 856 857 858 859 860 861 862 863 864 865 866 867 868 869 870 871 872 873 874 875 876 877 878 879 880 881 882 883 884 885 886 887 888 889 890 891 892 893 894 895 896 897 898 899 900 901 902 903 904 905 906 907 908 909 910 911 912 913 914 915 916 917 918 919 920 921 922 923 924 925 926 927 928 929 930 931 932 933 934 935 936 937 938 939 940 941 942 943 944 945 946 947 948 949 950 951 952 953 954 955 956 957 958 959 960 961 962 963 964 965 966 967 968 969 970 971 972 973 974 975 976 977 978 979 980 981 982 983 984 985 986 987 988 989 990 991 992 993 994 995 996 997 998 999 1000 1001 1002 1003 1004 1005 1006 1007 1008 1009 1010 1011 1012 1013 1014 1015 1016 1017 1018 1019 1020 1021 1022 1023 1024 1025 1026 1027 1028 1029 1030 1031 1032 1033 1034 1035 1036 1037 1038 1039 1040 1041 1042 1043 1044 1045 1046 1047 1048 1049 1050 1051 1052 1053 1054 1055 1056 1057 1058 1059 1060 1061 1062 1063 1064 1065 1066 1067 1068 1069 1070 1071 1072 1073 1074 1075 1076 1077 1078 1079 1080 1081 1082 1083 1084 1085 1086 1087 1088 1089 1090 1091 1092 1093 1094 1095 1096 1097 1098 1099 1100 1101 1102 1103 1104 1105 1106 1107 1108 1109 1110 1111 1112 1113 1114 1115 1116 1117 1118 1119 1120 1121 1122 1123 1124 1125 1126 1127 1128 1129 1130 1131 1132 1133 1134 1135 1136 1137 1138 1139 1140 1141 1142 1143 1144 1145 1146 1147 1148 1149 1150 1151 1152 1153 1154 1155 1156 1157 1158 1159 1160 1161 1162 1163 1164 1165 1166 1167 1168 1169 1170 1171 1172 1173 1174 1175 1176 1177 1178 1179 1180 1181 1182 1183 1184 1185 1186 1187 1188 1189 1190 1191 1192 1193 1194 1195 1196 1197 1198 1199 1200 1201 1202 1203 1204 1205 1206 1207 1208 1209 1210 1211 1212 1213 1214 1215 1216 1217 1218 1219 1220 1221 1222 1223 1224 1225 1226 1227
|
# coding: utf-8
#-------------------------------------------------------------------------
# Copyright (c) Microsoft Corporation. All rights reserved.
# Licensed under the MIT License. See License.txt in the project root for
# license information.
#--------------------------------------------------------------------------
# TEST SCENARIO COVERAGE
# ----------------------
# Methods Total : 132
# Methods Covered : 132
# Examples Total : 134
# Examples Tested : 134
# Coverage % : 100
# ----------------------
# Current Operation Coverage:
# DatabaseAccounts: 18/18
# Operations: 1/1
# Database: 3/3
# Collection: 3/3
# CollectionRegion: 1/1
# DatabaseAccountRegion: 1/1
# PercentileSourceTarget: 1/1
# PercentileTarget: 1/1
# Percentile: 1/1
# CollectionPartitionRegion: 1/1
# CollectionPartition: 2/2
# PartitionKeyRangeId: 1/1
# PartitionKeyRangeIdRegion: 1/1
# SqlResources: 28/28
# MongoDBResources: 16/16
# TableResources: 8/8
# CassandraResources: 16/16
# GremlinResources: 16/16
# NotebookWorkspaces: 7/7
# PrivateLinkResources: 2/2
# PrivateEndpointConnections: 4/4
import unittest
import azure.mgmt.cosmosdb
from devtools_testutils import AzureMgmtTestCase, RandomNameResourceGroupPreparer
AZURE_LOCATION = 'eastus'
class MgmtCosmosDBTest(AzureMgmtTestCase):
def setUp(self):
super(MgmtCosmosDBTest, self).setUp()
self.mgmt_client = self.create_mgmt_client(
azure.mgmt.cosmosdb.CosmosDBManagementClient
)
if self.is_live:
from azure.mgmt.network import NetworkManagementClient
self.network_client = self.create_mgmt_client(
NetworkManagementClient
)
def create_virtual_network(self, group_name, location, network_name, subnet_name):
azure_operation_poller = self.network_client.virtual_networks.create_or_update(
group_name,
network_name,
{
'location': location,
'address_space': {
'address_prefixes': ['10.0.0.0/16']
}
},
)
result_create = azure_operation_poller.result()
async_subnet_creation = self.network_client.subnets.create_or_update(
group_name,
network_name,
subnet_name,
{'address_prefix': '10.0.0.0/24'}
)
subnet_info = async_subnet_creation.result()
return subnet_info
@unittest.skip('hard to test')
@RandomNameResourceGroupPreparer(location=AZURE_LOCATION)
def test_cosmosdb(self, resource_group):
SUBSCRIPTION_ID = self.settings.SUBSCRIPTION_ID
TENANT_ID = self.settings.TENANT_ID
RESOURCE_GROUP = resource_group.name
ACCOUNT_NAME = "myAccount"
VIRTUAL_NETWORK_NAME = "myVirtualNetwork"
SUBNET_NAME = "mySubnet"
DATABASE_RID = "myDatabaseRid"
COLLECTION_RID = "myCollectionRid"
REGION = "myRegion"
SOURCE_REGION = "mySourceRegion"
TARGET_REGION = "myTargetRegion"
PERCENTILE_NAME = "myPercentile"
PARTITION_NAME = "myPartition"
PARTITION_KEY_RANGE_ID = "myPartitionKeyRangeId"
DATABASE_NAME = "myDatabase"
THROUGHPUT_SETTING_NAME = "myThroughputSetting"
CONTAINER_NAME = "myContainer"
STORED_PROCEDURE_NAME = "myStoredProcedure"
USER_DEFINED_FUNCTION_NAME = "myUserDefinedFunction"
TRIGGER_NAME = "myTrigger"
COLLECTION_NAME = "myCollection"
TABLE_NAME = "myTable"
KEYSPACE_NAME = "myKeyspace"
GRAPH_NAME = "myGraph"
NOTEBOOK_WORKSPACE_NAME = "myNotebookWorkspace"
GROUP_NAME = "myGroup"
PRIVATE_ENDPOINT_CONNECTION_NAME = "myPrivateEndpointConnection"
#--------------------------------------------------------------------------
# /DatabaseAccounts/put/CosmosDBDatabaseAccountCreateMin[put]
#--------------------------------------------------------------------------
BODY = {
"location": AZURE_LOCATION,
"database_account_offer_type": "Standard",
"locations": [
{
"failover_priority": "0",
"location_name": "southcentralus",
"is_zone_redundant": False
}
]
}
result = self.mgmt_client.database_accounts.begin_create_or_update(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, create_update_parameters=BODY)
result = result.result()
#--------------------------------------------------------------------------
# /DatabaseAccounts/put/CosmosDBDatabaseAccountCreateMax[put]
#--------------------------------------------------------------------------
BODY = {
"location": AZURE_LOCATION,
"kind": "MongoDB",
"database_account_offer_type": "Standard",
"ip_rules": [
{
"ip_address_or_range": "23.43.230.120"
},
{
"ip_address_or_range": "110.12.240.0/12"
}
],
"is_virtual_network_filter_enabled": True,
"virtual_network_rules": [
{
"id": "/subscriptions/" + SUBSCRIPTION_ID + "/resourceGroups/" + RESOURCE_GROUP + "/providers/Microsoft.Network/virtualNetworks/" + VIRTUAL_NETWORK_NAME + "/subnets/" + SUBNET_NAME,
"ignore_missing_vnet_service_endpoint": False
}
],
"locations": [
{
"failover_priority": "0",
"location_name": "southcentralus",
"is_zone_redundant": False
},
{
"failover_priority": "1",
"location_name": "eastus",
"is_zone_redundant": False
}
],
"consistency_policy": {
"default_consistency_level": "BoundedStaleness",
"max_interval_in_seconds": "10",
"max_staleness_prefix": "200"
},
"key_vault_key_uri": "https://myKeyVault.vault.azure.net",
"enable_free_tier": False,
"api_properties": {
"server_version": "3.2"
},
"enable_analytical_storage": True,
"cors": [
{
"allowed_origins": "https://test"
}
]
}
# result = self.mgmt_client.database_accounts.begin_create_or_update(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, create_update_parameters=BODY)
# result = result.result()
#--------------------------------------------------------------------------
# /TableResources/put/CosmosDBTableReplace[put]
#--------------------------------------------------------------------------
BODY = {
"location": AZURE_LOCATION,
"resource": {
"id": "tableName"
}
}
result = self.mgmt_client.table_resources.begin_create_update_table(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, table_name=TABLE_NAME, create_update_table_parameters=BODY)
result = result.result()
#--------------------------------------------------------------------------
# /SqlResources/put/CosmosDBSqlDatabaseCreateUpdate[put]
#--------------------------------------------------------------------------
BODY = {
"location": AZURE_LOCATION,
"resource": {
"id": "databaseName"
}
}
result = self.mgmt_client.sql_resources.begin_create_update_sql_database(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, create_update_sql_database_parameters=BODY)
result = result.result()
#--------------------------------------------------------------------------
# /MongoDBResources/put/CosmosDBMongoDBDatabaseCreateUpdate[put]
#--------------------------------------------------------------------------
BODY = {
"location": AZURE_LOCATION,
"resource": {
"id": "databaseName"
}
}
result = self.mgmt_client.mongo_dbresources.begin_create_update_mongo_dbdatabase(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, create_update_mongo_dbdatabase_parameters=BODY)
result = result.result()
#--------------------------------------------------------------------------
# /GremlinResources/put/CosmosDBGremlinDatabaseCreateUpdate[put]
#--------------------------------------------------------------------------
BODY = {
"location": AZURE_LOCATION,
"resource": {
"id": "databaseName"
}
}
result = self.mgmt_client.gremlin_resources.begin_create_update_gremlin_database(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, create_update_gremlin_database_parameters=BODY)
result = result.result()
#--------------------------------------------------------------------------
# /CassandraResources/put/CosmosDBCassandraKeyspaceCreateUpdate[put]
#--------------------------------------------------------------------------
BODY = {
"location": AZURE_LOCATION,
"resource": {
"id": "keyspaceName"
}
}
result = self.mgmt_client.cassandra_resources.begin_create_update_cassandra_keyspace(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, keyspace_name=KEYSPACE_NAME, create_update_cassandra_keyspace_parameters=BODY)
result = result.result()
#--------------------------------------------------------------------------
# /NotebookWorkspaces/put/CosmosDBNotebookWorkspaceCreate[put]
#--------------------------------------------------------------------------
BODY = {}
result = self.mgmt_client.notebook_workspaces.begin_create_or_update(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, notebook_workspace_name=NOTEBOOK_WORKSPACE_NAME, notebook_create_update_parameters=BODY)
result = result.result()
#--------------------------------------------------------------------------
# /GremlinResources/put/CosmosDBGremlinGraphCreateUpdate[put]
#--------------------------------------------------------------------------
BODY = {
"location": AZURE_LOCATION,
"resource": {
"id": "graphName",
"indexing_policy": {
"indexing_mode": "Consistent",
"automatic": True,
"included_paths": [
{
"path": "/*",
"indexes": [
{
"kind": "Range",
"data_type": "String",
"precision": "-1"
},
{
"kind": "Range",
"data_type": "Number",
"precision": "-1"
}
]
}
],
"excluded_paths": []
},
"partition_key": {
"paths": [
"/AccountNumber"
],
"kind": "Hash"
},
"default_ttl": "100",
"unique_key_policy": {
"unique_keys": [
{
"paths": [
"/testPath"
]
}
]
},
"conflict_resolution_policy": {
"mode": "LastWriterWins",
"conflict_resolution_path": "/path"
}
}
}
result = self.mgmt_client.gremlin_resources.begin_create_update_gremlin_graph(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, graph_name=GRAPH_NAME, create_update_gremlin_graph_parameters=BODY)
result = result.result()
#--------------------------------------------------------------------------
# /CassandraResources/put/CosmosDBCassandraTableCreateUpdate[put]
#--------------------------------------------------------------------------
BODY = {
"location": AZURE_LOCATION,
"resource": {
"id": "tableName",
"default_ttl": "100",
"analytical_storage_ttl": "500",
"schema": {
"columns": [
{
"name": "columnA",
"type": "Ascii"
}
],
"partition_keys": [
{
"name": "columnA"
}
],
"cluster_keys": [
{
"name": "columnA",
"order_by": "Asc"
}
]
}
}
}
result = self.mgmt_client.cassandra_resources.begin_create_update_cassandra_table(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, keyspace_name=KEYSPACE_NAME, table_name=TABLE_NAME, create_update_cassandra_table_parameters=BODY)
result = result.result()
#--------------------------------------------------------------------------
# /SqlResources/put/CosmosDBSqlContainerCreateUpdate[put]
#--------------------------------------------------------------------------
BODY = {
"location": AZURE_LOCATION,
"resource": {
"id": "containerName",
"indexing_policy": {
"indexing_mode": "Consistent",
"automatic": True,
"included_paths": [
{
"path": "/*",
"indexes": [
{
"kind": "Range",
"data_type": "String",
"precision": "-1"
},
{
"kind": "Range",
"data_type": "Number",
"precision": "-1"
}
]
}
],
"excluded_paths": []
},
"partition_key": {
"paths": [
"/AccountNumber"
],
"kind": "Hash"
},
"default_ttl": "100",
"unique_key_policy": {
"unique_keys": [
{
"paths": [
"/testPath"
]
}
]
},
"conflict_resolution_policy": {
"mode": "LastWriterWins",
"conflict_resolution_path": "/path"
}
}
}
result = self.mgmt_client.sql_resources.begin_create_update_sql_container(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, container_name=CONTAINER_NAME, create_update_sql_container_parameters=BODY)
result = result.result()
#--------------------------------------------------------------------------
# /PrivateEndpointConnections/put/Approve or reject a private endpoint connection with a given name.[put]
#--------------------------------------------------------------------------
BODY = {
"private_link_service_connection_state": {
"status": "Approved",
"description": "Approved by johndoe@contoso.com"
}
}
result = self.mgmt_client.private_endpoint_connections.begin_create_or_update(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, private_endpoint_connection_name=PRIVATE_ENDPOINT_CONNECTION_NAME, parameters=BODY)
result = result.result()
#--------------------------------------------------------------------------
# /MongoDBResources/put/CosmosDBMongoDBCollectionCreateUpdate[put]
#--------------------------------------------------------------------------
BODY = {
"location": AZURE_LOCATION,
"resource": {
"id": "collectionName",
"indexes": [
{
"key": {
"keys": [
"testKey"
]
},
"options": {
"expire_after_seconds": "100",
"unique": True
}
}
],
"shard_key": {
"test_key": "Hash"
},
"analytical_storage_ttl": "500"
}
}
result = self.mgmt_client.mongo_dbresources.begin_create_update_mongo_dbcollection(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, collection_name=COLLECTION_NAME, create_update_mongo_dbcollection_parameters=BODY)
result = result.result()
#--------------------------------------------------------------------------
# /TableResources/put/CosmosDBTableThroughputUpdate[put]
#--------------------------------------------------------------------------
BODY = {
"location": AZURE_LOCATION,
"resource": {
"throughput": "400"
}
}
result = self.mgmt_client.table_resources.begin_update_table_throughput(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, table_name=TABLE_NAME, throughput_setting_name=THROUGHPUT_SETTING_NAME, update_throughput_parameters=BODY)
result = result.result()
#--------------------------------------------------------------------------
# /SqlResources/put/CosmosDBSqlDatabaseThroughputUpdate[put]
#--------------------------------------------------------------------------
BODY = {
"location": AZURE_LOCATION,
"resource": {
"throughput": "400"
}
}
result = self.mgmt_client.sql_resources.begin_update_sql_database_throughput(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, throughput_setting_name=THROUGHPUT_SETTING_NAME, update_throughput_parameters=BODY)
result = result.result()
#--------------------------------------------------------------------------
# /MongoDBResources/put/CosmosDBMongoDBDatabaseThroughputUpdate[put]
#--------------------------------------------------------------------------
BODY = {
"location": AZURE_LOCATION,
"resource": {
"throughput": "400"
}
}
result = self.mgmt_client.mongo_dbresources.begin_update_mongo_dbdatabase_throughput(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, throughput_setting_name=THROUGHPUT_SETTING_NAME, update_throughput_parameters=BODY)
result = result.result()
#--------------------------------------------------------------------------
# /GremlinResources/put/CosmosDBGremlinDatabaseThroughputUpdate[put]
#--------------------------------------------------------------------------
BODY = {
"location": AZURE_LOCATION,
"resource": {
"throughput": "400"
}
}
result = self.mgmt_client.gremlin_resources.begin_update_gremlin_database_throughput(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, throughput_setting_name=THROUGHPUT_SETTING_NAME, update_throughput_parameters=BODY)
result = result.result()
#--------------------------------------------------------------------------
# /CassandraResources/put/CosmosDBCassandraKeyspaceThroughputUpdate[put]
#--------------------------------------------------------------------------
BODY = {
"location": AZURE_LOCATION,
"resource": {
"throughput": "400"
}
}
result = self.mgmt_client.cassandra_resources.begin_update_cassandra_keyspace_throughput(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, keyspace_name=KEYSPACE_NAME, throughput_setting_name=THROUGHPUT_SETTING_NAME, update_throughput_parameters=BODY)
result = result.result()
#--------------------------------------------------------------------------
# /SqlResources/put/CosmosDBSqlTriggerCreateUpdate[put]
#--------------------------------------------------------------------------
BODY = {
"resource": {
"id": "triggerName",
"body": "body",
"trigger_type": "triggerType",
"trigger_operation": "triggerOperation"
}
}
result = self.mgmt_client.sql_resources.begin_create_update_sql_trigger(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, container_name=CONTAINER_NAME, trigger_name=TRIGGER_NAME, create_update_sql_trigger_parameters=BODY)
result = result.result()
#--------------------------------------------------------------------------
# /GremlinResources/put/CosmosDBGremlinGraphThroughputUpdate[put]
#--------------------------------------------------------------------------
BODY = {
"location": AZURE_LOCATION,
"resource": {
"throughput": "400"
}
}
result = self.mgmt_client.gremlin_resources.begin_update_gremlin_graph_throughput(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, graph_name=GRAPH_NAME, throughput_setting_name=THROUGHPUT_SETTING_NAME, update_throughput_parameters=BODY)
result = result.result()
#--------------------------------------------------------------------------
# /SqlResources/put/CosmosDBSqlStoredProcedureCreateUpdate[put]
#--------------------------------------------------------------------------
BODY = {
"resource": {
"id": "storedProcedureName",
"body": "body"
}
}
result = self.mgmt_client.sql_resources.begin_create_update_sql_stored_procedure(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, container_name=CONTAINER_NAME, stored_procedure_name=STORED_PROCEDURE_NAME, create_update_sql_stored_procedure_parameters=BODY)
result = result.result()
#--------------------------------------------------------------------------
# /CassandraResources/put/CosmosDBCassandraTableThroughputUpdate[put]
#--------------------------------------------------------------------------
BODY = {
"location": AZURE_LOCATION,
"resource": {
"throughput": "400"
}
}
result = self.mgmt_client.cassandra_resources.begin_update_cassandra_table_throughput(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, keyspace_name=KEYSPACE_NAME, table_name=TABLE_NAME, throughput_setting_name=THROUGHPUT_SETTING_NAME, update_throughput_parameters=BODY)
result = result.result()
#--------------------------------------------------------------------------
# /SqlResources/put/CosmosDBSqlContainerThroughputUpdate[put]
#--------------------------------------------------------------------------
BODY = {
"location": AZURE_LOCATION,
"resource": {
"throughput": "400"
}
}
result = self.mgmt_client.sql_resources.begin_update_sql_container_throughput(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, container_name=CONTAINER_NAME, throughput_setting_name=THROUGHPUT_SETTING_NAME, update_throughput_parameters=BODY)
result = result.result()
#--------------------------------------------------------------------------
# /SqlResources/put/CosmosDBSqlUserDefinedFunctionCreateUpdate[put]
#--------------------------------------------------------------------------
BODY = {
"resource": {
"id": "userDefinedFunctionName",
"body": "body"
}
}
result = self.mgmt_client.sql_resources.begin_create_update_sql_user_defined_function(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, container_name=CONTAINER_NAME, user_defined_function_name=USER_DEFINED_FUNCTION_NAME, create_update_sql_user_defined_function_parameters=BODY)
result = result.result()
#--------------------------------------------------------------------------
# /MongoDBResources/put/CosmosDBMongoDBCollectionThroughputUpdate[put]
#--------------------------------------------------------------------------
BODY = {
"location": AZURE_LOCATION,
"resource": {
"throughput": "400"
}
}
result = self.mgmt_client.mongo_dbresources.begin_update_mongo_dbcollection_throughput(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, collection_name=COLLECTION_NAME, throughput_setting_name=THROUGHPUT_SETTING_NAME, update_throughput_parameters=BODY)
result = result.result()
#--------------------------------------------------------------------------
# /PartitionKeyRangeIdRegion/get/CosmosDBDatabaseAccountRegionGetMetrics[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.partition_key_range_id_region.list_metrics(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, region=REGION, database_rid=DATABASE_RID, collection_rid=COLLECTION_RID, partition_key_range_id=PARTITION_KEY_RANGE_ID, filter="$filter=(name.value eq 'Max RUs Per Second') and timeGrain eq duration'PT1M' and startTime eq '2017-11-19T23:53:55.2780000Z' and endTime eq '2017-11-20T23:58:55.2780000Z")
#--------------------------------------------------------------------------
# /MongoDBResources/get/CosmosDBMongoDBCollectionThroughputGet[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.mongo_dbresources.get_mongo_dbcollection_throughput(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, collection_name=COLLECTION_NAME, throughput_setting_name=THROUGHPUT_SETTING_NAME)
#--------------------------------------------------------------------------
# /SqlResources/get/CosmosDBSqlUserDefinedFunctionGet[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.sql_resources.get_sql_user_defined_function(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, container_name=CONTAINER_NAME, user_defined_function_name=USER_DEFINED_FUNCTION_NAME)
#--------------------------------------------------------------------------
# /PartitionKeyRangeId/get/CosmosDBDatabaseAccountRegionGetMetrics[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.partition_key_range_id.list_metrics(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_rid=DATABASE_RID, collection_rid=COLLECTION_RID, partition_key_range_id=PARTITION_KEY_RANGE_ID, filter="$filter=(name.value eq 'Max RUs Per Second') and timeGrain eq duration'PT1M' and startTime eq '2017-11-19T23:53:55.2780000Z' and endTime eq '2017-11-20T23:58:55.2780000Z")
#--------------------------------------------------------------------------
# /CollectionPartitionRegion/get/CosmosDBDatabaseAccountRegionGetMetrics[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.collection_partition_region.list_metrics(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, region=REGION, database_rid=DATABASE_RID, collection_rid=COLLECTION_RID, partition_name=PARTITION_NAME, filter="$filter=(name.value eq 'Max RUs Per Second') and timeGrain eq duration'PT1M' and startTime eq '2017-11-19T23:53:55.2780000Z' and endTime eq '2017-11-20T23:58:55.2780000Z")
#--------------------------------------------------------------------------
# /SqlResources/get/CosmosDBSqlContainerThroughputGet[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.sql_resources.get_sql_container_throughput(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, container_name=CONTAINER_NAME, throughput_setting_name=THROUGHPUT_SETTING_NAME)
#--------------------------------------------------------------------------
# /CassandraResources/get/CosmosDBCassandraTableThroughputGet[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.cassandra_resources.get_cassandra_table_throughput(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, keyspace_name=KEYSPACE_NAME, table_name=TABLE_NAME, throughput_setting_name=THROUGHPUT_SETTING_NAME)
#--------------------------------------------------------------------------
# /SqlResources/get/CosmosDBSqlStoredProcedureGet[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.sql_resources.get_sql_stored_procedure(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, container_name=CONTAINER_NAME, stored_procedure_name=STORED_PROCEDURE_NAME)
#--------------------------------------------------------------------------
# /GremlinResources/get/CosmosDBGremlinGraphThroughputGet[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.gremlin_resources.get_gremlin_graph_throughput(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, graph_name=GRAPH_NAME, throughput_setting_name=THROUGHPUT_SETTING_NAME)
#--------------------------------------------------------------------------
# /PercentileSourceTarget/get/CosmosDBDatabaseAccountRegionGetMetrics[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.percentile_source_target.list_metrics(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, source_region=SOURCE_REGION, target_region=TARGET_REGION, percentile_name=PERCENTILE_NAME, filter="$filter=(name.value eq 'Probabilistic Bounded Staleness') and timeGrain eq duration'PT5M' and startTime eq '2017-11-19T23:53:55.2780000Z' and endTime eq '2017-11-20T00:13:55.2780000Z")
#--------------------------------------------------------------------------
# /CollectionPartition/get/CosmosDBDatabaseAccountRegionGetMetrics[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.collection_partition.list_metrics(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_rid=DATABASE_RID, collection_rid=COLLECTION_RID, partition_name=PARTITION_NAME, filter="$filter=(name.value eq 'Max RUs Per Second') and timeGrain eq duration'PT1M' and startTime eq '2017-11-19T23:53:55.2780000Z' and endTime eq '2017-11-20T23:58:55.2780000Z")
#--------------------------------------------------------------------------
# /CollectionPartition/get/CosmosDBCollectionGetUsages[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.collection_partition.list_usages(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_rid=DATABASE_RID, collection_rid=COLLECTION_RID, partition_name=PARTITION_NAME, filter="$filter=name.value eq 'Partition Storage'")
#--------------------------------------------------------------------------
# /SqlResources/get/CosmosDBSqlTriggerGet[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.sql_resources.get_sql_trigger(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, container_name=CONTAINER_NAME, trigger_name=TRIGGER_NAME)
#--------------------------------------------------------------------------
# /CollectionRegion/get/CosmosDBRegionCollectionGetMetrics[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.collection_region.list_metrics(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, region=REGION, database_rid=DATABASE_RID, collection_rid=COLLECTION_RID, filter="$filter=(name.value eq 'Total Requests') and timeGrain eq duration'PT5M' and startTime eq '2017-11-19T23:53:55.2780000Z' and endTime eq '2017-11-20T00:13:55.2780000Z")
#--------------------------------------------------------------------------
# /CassandraResources/get/CosmosDBCassandraKeyspaceThroughputGet[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.cassandra_resources.get_cassandra_keyspace_throughput(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, keyspace_name=KEYSPACE_NAME, throughput_setting_name=THROUGHPUT_SETTING_NAME)
#--------------------------------------------------------------------------
# /GremlinResources/get/CosmosDBGremlinDatabaseThroughputGet[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.gremlin_resources.get_gremlin_database_throughput(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, throughput_setting_name=THROUGHPUT_SETTING_NAME)
#--------------------------------------------------------------------------
# /SqlResources/get/CosmosDBSqlUserDefinedFunctionList[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.sql_resources.list_sql_user_defined_functions(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, container_name=CONTAINER_NAME)
#--------------------------------------------------------------------------
# /MongoDBResources/get/CosmosDBMongoDBDatabaseThroughputGet[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.mongo_dbresources.get_mongo_dbdatabase_throughput(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, throughput_setting_name=THROUGHPUT_SETTING_NAME)
#--------------------------------------------------------------------------
# /SqlResources/get/CosmosDBSqlStoredProcedureList[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.sql_resources.list_sql_stored_procedures(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, container_name=CONTAINER_NAME)
#--------------------------------------------------------------------------
# /SqlResources/get/CosmosDBSqlDatabaseThroughputGet[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.sql_resources.get_sql_database_throughput(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, throughput_setting_name=THROUGHPUT_SETTING_NAME)
#--------------------------------------------------------------------------
# /Collection/get/CosmosDBCollectionGetMetricDefinitions[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.collection.list_metric_definitions(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_rid=DATABASE_RID, collection_rid=COLLECTION_RID)
#--------------------------------------------------------------------------
# /SqlResources/get/CosmosDBSqlTriggerList[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.sql_resources.list_sql_triggers(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, container_name=CONTAINER_NAME)
#--------------------------------------------------------------------------
# /TableResources/get/CosmosDBTableThroughputGet[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.table_resources.get_table_throughput(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, table_name=TABLE_NAME, throughput_setting_name=THROUGHPUT_SETTING_NAME)
#--------------------------------------------------------------------------
# /MongoDBResources/get/CosmosDBMongoDBCollectionGet[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.mongo_dbresources.get_mongo_dbcollection(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, collection_name=COLLECTION_NAME)
#--------------------------------------------------------------------------
# /Collection/get/CosmosDBCollectionGetMetrics[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.collection.list_metrics(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_rid=DATABASE_RID, collection_rid=COLLECTION_RID, filter="$filter=(name.value eq 'Total Requests') and timeGrain eq duration'PT5M' and startTime eq '2017-11-19T23:53:55.2780000Z' and endTime eq '2017-11-20T00:13:55.2780000Z")
#--------------------------------------------------------------------------
# /Collection/get/CosmosDBCollectionGetUsages[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.collection.list_usages(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_rid=DATABASE_RID, collection_rid=COLLECTION_RID, filter="$filter=name.value eq 'Storage'")
#--------------------------------------------------------------------------
# /PercentileTarget/get/CosmosDBDatabaseAccountRegionGetMetrics[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.percentile_target.list_metrics(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, target_region=TARGET_REGION, percentile_name=PERCENTILE_NAME, filter="$filter=(name.value eq 'Probabilistic Bounded Staleness') and timeGrain eq duration'PT5M' and startTime eq '2017-11-19T23:53:55.2780000Z' and endTime eq '2017-11-20T00:13:55.2780000Z")
#--------------------------------------------------------------------------
# /PrivateEndpointConnections/get/Gets private endpoint connection.[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.private_endpoint_connections.list_by_database_account(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME)
#--------------------------------------------------------------------------
# /SqlResources/get/CosmosDBSqlContainerGet[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.sql_resources.get_sql_container(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, container_name=CONTAINER_NAME)
#--------------------------------------------------------------------------
# /CassandraResources/get/CosmosDBCassandraTableGet[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.cassandra_resources.get_cassandra_table(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, keyspace_name=KEYSPACE_NAME, table_name=TABLE_NAME)
#--------------------------------------------------------------------------
# /GremlinResources/get/CosmosDBGremlinGraphGet[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.gremlin_resources.get_gremlin_graph(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, graph_name=GRAPH_NAME)
#--------------------------------------------------------------------------
# /MongoDBResources/get/CosmosDBMongoDBCollectionList[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.mongo_dbresources.list_mongo_dbcollections(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME)
#--------------------------------------------------------------------------
# /NotebookWorkspaces/get/CosmosDBNotebookWorkspaceGet[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.notebook_workspaces.get(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, notebook_workspace_name=NOTEBOOK_WORKSPACE_NAME)
#--------------------------------------------------------------------------
# /Database/get/CosmosDBDatabaseGetMetricDefinitions[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.database.list_metric_definitions(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_rid=DATABASE_RID)
#--------------------------------------------------------------------------
# /CassandraResources/get/CosmosDBCassandraTableList[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.cassandra_resources.list_cassandra_tables(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, keyspace_name=KEYSPACE_NAME)
#--------------------------------------------------------------------------
# /GremlinResources/get/CosmosDBGremlinGraphList[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.gremlin_resources.list_gremlin_graphs(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME)
#--------------------------------------------------------------------------
# /SqlResources/get/CosmosDBSqlContainerList[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.sql_resources.list_sql_containers(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME)
#--------------------------------------------------------------------------
# /CassandraResources/get/CosmosDBCassandraKeyspaceGet[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.cassandra_resources.get_cassandra_keyspace(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, keyspace_name=KEYSPACE_NAME)
#--------------------------------------------------------------------------
# /PrivateLinkResources/get/Gets private endpoint connection.[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.private_link_resources.list_by_database_account(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME)
#--------------------------------------------------------------------------
# /Database/get/CosmosDBDatabaseGetMetrics[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.database.list_metrics(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_rid=DATABASE_RID, filter="$filter=(name.value eq 'Total Requests') and timeGrain eq duration'PT5M' and startTime eq '2017-11-19T23:53:55.2780000Z' and endTime eq '2017-11-20T00:13:55.2780000Z")
#--------------------------------------------------------------------------
# /GremlinResources/get/CosmosDBGremlinDatabaseGet[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.gremlin_resources.get_gremlin_database(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME)
#--------------------------------------------------------------------------
# /MongoDBResources/get/CosmosDBMongoDBDatabaseGet[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.mongo_dbresources.get_mongo_dbdatabase(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME)
#--------------------------------------------------------------------------
# /Database/get/CosmosDBDatabaseGetUsages[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.database.list_usages(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_rid=DATABASE_RID, filter="$filter=name.value eq 'Storage'")
#--------------------------------------------------------------------------
# /Percentile/get/CosmosDBDatabaseAccountRegionGetMetrics[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.percentile.list_metrics(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, percentile_name=PERCENTILE_NAME, filter="$filter=(name.value eq 'Probabilistic Bounded Staleness') and timeGrain eq duration'PT5M' and startTime eq '2017-11-19T23:53:55.2780000Z' and endTime eq '2017-11-20T00:13:55.2780000Z")
#--------------------------------------------------------------------------
# /SqlResources/get/CosmosDBSqlDatabaseGet[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.sql_resources.get_sql_database(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME)
#--------------------------------------------------------------------------
# /DatabaseAccountRegion/get/CosmosDBDatabaseAccountRegionGetMetrics[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.database_account_region.list_metrics(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, region=REGION, filter="$filter=(name.value eq 'Total Requests') and timeGrain eq duration'PT5M' and startTime eq '2017-11-19T23:53:55.2780000Z' and endTime eq '2017-11-20T00:13:55.2780000Z")
#--------------------------------------------------------------------------
# /PrivateEndpointConnections/get/Gets private endpoint connection.[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.private_endpoint_connections.list_by_database_account(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME)
#--------------------------------------------------------------------------
# /TableResources/get/CosmosDBTableGet[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.table_resources.get_table(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, table_name=TABLE_NAME)
#--------------------------------------------------------------------------
# /PrivateLinkResources/get/Gets private endpoint connection.[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.private_link_resources.list_by_database_account(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME)
#--------------------------------------------------------------------------
# /CassandraResources/get/CosmosDBCassandraKeyspaceList[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.cassandra_resources.list_cassandra_keyspaces(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME)
#--------------------------------------------------------------------------
# /NotebookWorkspaces/get/CosmosDBNotebookWorkspaceList[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.notebook_workspaces.list_by_database_account(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME)
#--------------------------------------------------------------------------
# /DatabaseAccounts/get/CosmosDBDatabaseAccountGetMetricDefinitions[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.database_accounts.list_metric_definitions(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME)
#--------------------------------------------------------------------------
# /MongoDBResources/get/CosmosDBMongoDBDatabaseList[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.mongo_dbresources.list_mongo_dbdatabases(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME)
#--------------------------------------------------------------------------
# /GremlinResources/get/CosmosDBGremlinDatabaseList[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.gremlin_resources.list_gremlin_databases(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME)
#--------------------------------------------------------------------------
# /SqlResources/get/CosmosDBSqlDatabaseList[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.sql_resources.list_sql_databases(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME)
#--------------------------------------------------------------------------
# /DatabaseAccounts/get/CosmosDBDatabaseAccountListReadOnlyKeys[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.database_accounts.get_read_only_keys(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME)
#--------------------------------------------------------------------------
# /DatabaseAccounts/get/CosmosDBDatabaseAccountGetMetrics[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.database_accounts.list_metrics(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, filter="$filter=(name.value eq 'Total Requests') and timeGrain eq duration'PT5M' and startTime eq '2017-11-19T23:53:55.2780000Z' and endTime eq '2017-11-20T00:13:55.2780000Z")
#--------------------------------------------------------------------------
# /DatabaseAccounts/get/CosmosDBDatabaseAccountGetUsages[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.database_accounts.list_usages(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, filter="$filter=name.value eq 'Storage'")
#--------------------------------------------------------------------------
# /TableResources/get/CosmosDBTableList[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.table_resources.list_tables(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME)
#--------------------------------------------------------------------------
# /DatabaseAccounts/get/CosmosDBDatabaseAccountGet[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.database_accounts.get(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME)
#--------------------------------------------------------------------------
# /DatabaseAccounts/get/CosmosDBDatabaseAccountListByResourceGroup[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.database_accounts.list_by_resource_group(resource_group_name=RESOURCE_GROUP)
#--------------------------------------------------------------------------
# /DatabaseAccounts/get/CosmosDBDatabaseAccountList[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.database_accounts.list()
#--------------------------------------------------------------------------
# /Operations/get/CosmosDBOperationsList[get]
#--------------------------------------------------------------------------
result = self.mgmt_client.operations.list()
#--------------------------------------------------------------------------
# /MongoDBResources/post/CosmosDBMongoDBCollectionMigrateToManualThroughput[post]
#--------------------------------------------------------------------------
result = self.mgmt_client.mongo_dbresources.begin_migrate_mongo_dbcollection_to_manual_throughput(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, collection_name=COLLECTION_NAME, throughput_setting_name=THROUGHPUT_SETTING_NAME)
result = result.result()
#--------------------------------------------------------------------------
# /SqlResources/post/CosmosDBSqlContainerMigrateToManualThroughput[post]
#--------------------------------------------------------------------------
result = self.mgmt_client.sql_resources.begin_migrate_sql_container_to_manual_throughput(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, container_name=CONTAINER_NAME, throughput_setting_name=THROUGHPUT_SETTING_NAME)
result = result.result()
#--------------------------------------------------------------------------
# /MongoDBResources/post/CosmosDBMongoDBCollectionMigrateToAutoscale[post]
#--------------------------------------------------------------------------
result = self.mgmt_client.mongo_dbresources.begin_migrate_mongo_dbcollection_to_autoscale(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, collection_name=COLLECTION_NAME, throughput_setting_name=THROUGHPUT_SETTING_NAME)
result = result.result()
#--------------------------------------------------------------------------
# /CassandraResources/post/CosmosDBCassandraTableMigrateToManualThroughput[post]
#--------------------------------------------------------------------------
result = self.mgmt_client.cassandra_resources.begin_migrate_cassandra_table_to_manual_throughput(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, keyspace_name=KEYSPACE_NAME, table_name=TABLE_NAME, throughput_setting_name=THROUGHPUT_SETTING_NAME)
result = result.result()
#--------------------------------------------------------------------------
# /GremlinResources/post/CosmosDBGremlinGraphMigrateToManualThroughput[post]
#--------------------------------------------------------------------------
result = self.mgmt_client.gremlin_resources.begin_migrate_gremlin_graph_to_manual_throughput(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, graph_name=GRAPH_NAME, throughput_setting_name=THROUGHPUT_SETTING_NAME)
result = result.result()
#--------------------------------------------------------------------------
# /SqlResources/post/CosmosDBSqlContainerMigrateToAutoscale[post]
#--------------------------------------------------------------------------
result = self.mgmt_client.sql_resources.begin_migrate_sql_container_to_autoscale(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, container_name=CONTAINER_NAME, throughput_setting_name=THROUGHPUT_SETTING_NAME)
result = result.result()
#--------------------------------------------------------------------------
# /CassandraResources/post/CosmosDBCassandraTableMigrateToAutoscale[post]
#--------------------------------------------------------------------------
result = self.mgmt_client.cassandra_resources.begin_migrate_cassandra_table_to_autoscale(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, keyspace_name=KEYSPACE_NAME, table_name=TABLE_NAME, throughput_setting_name=THROUGHPUT_SETTING_NAME)
result = result.result()
#--------------------------------------------------------------------------
# /GremlinResources/post/CosmosDBGremlinGraphMigrateToAutoscale[post]
#--------------------------------------------------------------------------
result = self.mgmt_client.gremlin_resources.begin_migrate_gremlin_graph_to_autoscale(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, graph_name=GRAPH_NAME, throughput_setting_name=THROUGHPUT_SETTING_NAME)
result = result.result()
#--------------------------------------------------------------------------
# /CassandraResources/post/CosmosDBCassandraKeyspaceMigrateToManualThroughput[post]
#--------------------------------------------------------------------------
result = self.mgmt_client.cassandra_resources.begin_migrate_cassandra_keyspace_to_manual_throughput(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, keyspace_name=KEYSPACE_NAME, throughput_setting_name=THROUGHPUT_SETTING_NAME)
result = result.result()
#--------------------------------------------------------------------------
# /MongoDBResources/post/CosmosDBMongoDBDatabaseMigrateToManualThroughput[post]
#--------------------------------------------------------------------------
result = self.mgmt_client.mongo_dbresources.begin_migrate_mongo_dbdatabase_to_manual_throughput(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, throughput_setting_name=THROUGHPUT_SETTING_NAME)
result = result.result()
#--------------------------------------------------------------------------
# /GremlinResources/post/CosmosDBGremlinDatabaseMigrateToManualThroughput[post]
#--------------------------------------------------------------------------
result = self.mgmt_client.gremlin_resources.begin_migrate_gremlin_database_to_manual_throughput(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, throughput_setting_name=THROUGHPUT_SETTING_NAME)
result = result.result()
#--------------------------------------------------------------------------
# /SqlResources/post/CosmosDBSqlDatabaseMigrateToManualThroughput[post]
#--------------------------------------------------------------------------
result = self.mgmt_client.sql_resources.begin_migrate_sql_database_to_manual_throughput(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, throughput_setting_name=THROUGHPUT_SETTING_NAME)
result = result.result()
#--------------------------------------------------------------------------
# /CassandraResources/post/CosmosDBCassandraKeyspaceMigrateToAutoscale[post]
#--------------------------------------------------------------------------
result = self.mgmt_client.cassandra_resources.begin_migrate_cassandra_keyspace_to_autoscale(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, keyspace_name=KEYSPACE_NAME, throughput_setting_name=THROUGHPUT_SETTING_NAME)
result = result.result()
#--------------------------------------------------------------------------
# /MongoDBResources/post/CosmosDBMongoDBDatabaseMigrateToAutoscale[post]
#--------------------------------------------------------------------------
result = self.mgmt_client.mongo_dbresources.begin_migrate_mongo_dbdatabase_to_autoscale(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, throughput_setting_name=THROUGHPUT_SETTING_NAME)
result = result.result()
#--------------------------------------------------------------------------
# /GremlinResources/post/CosmosDBGremlinDatabaseMigrateToAutoscale[post]
#--------------------------------------------------------------------------
result = self.mgmt_client.gremlin_resources.begin_migrate_gremlin_database_to_autoscale(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, throughput_setting_name=THROUGHPUT_SETTING_NAME)
result = result.result()
#--------------------------------------------------------------------------
# /SqlResources/post/CosmosDBSqlDatabaseMigrateToAutoscale[post]
#--------------------------------------------------------------------------
result = self.mgmt_client.sql_resources.begin_migrate_sql_database_to_autoscale(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, throughput_setting_name=THROUGHPUT_SETTING_NAME)
result = result.result()
#--------------------------------------------------------------------------
# /TableResources/post/CosmosDBTableMigrateToManualThroughput[post]
#--------------------------------------------------------------------------
result = self.mgmt_client.table_resources.begin_migrate_table_to_manual_throughput(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, table_name=TABLE_NAME, throughput_setting_name=THROUGHPUT_SETTING_NAME)
result = result.result()
#--------------------------------------------------------------------------
# /TableResources/post/CosmosDBTableMigrateToAutoscale[post]
#--------------------------------------------------------------------------
result = self.mgmt_client.table_resources.begin_migrate_table_to_autoscale(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, table_name=TABLE_NAME, throughput_setting_name=THROUGHPUT_SETTING_NAME)
result = result.result()
#--------------------------------------------------------------------------
# /NotebookWorkspaces/post/CosmosDBNotebookWorkspaceRegenerateAuthToken[post]
#--------------------------------------------------------------------------
result = self.mgmt_client.notebook_workspaces.begin_regenerate_auth_token(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, notebook_workspace_name=NOTEBOOK_WORKSPACE_NAME)
result = result.result()
#--------------------------------------------------------------------------
# /NotebookWorkspaces/post/CosmosDBNotebookWorkspaceListConnectionInfo[post]
#--------------------------------------------------------------------------
result = self.mgmt_client.notebook_workspaces.list_connection_info(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, notebook_workspace_name=NOTEBOOK_WORKSPACE_NAME)
#--------------------------------------------------------------------------
# /NotebookWorkspaces/post/CosmosDBNotebookWorkspaceStart[post]
#--------------------------------------------------------------------------
result = self.mgmt_client.notebook_workspaces.begin_start(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, notebook_workspace_name=NOTEBOOK_WORKSPACE_NAME)
result = result.result()
#--------------------------------------------------------------------------
# /DatabaseAccounts/post/CosmosDBDatabaseAccountFailoverPriorityChange[post]
#--------------------------------------------------------------------------
BODY = {
"failover_policies": [
{
"location_name": "eastus",
"failover_priority": "0"
},
{
"location_name": "westus",
"failover_priority": "1"
}
]
}
result = self.mgmt_client.database_accounts.begin_failover_priority_change(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, failover_parameters=BODY)
result = result.result()
#--------------------------------------------------------------------------
# /DatabaseAccounts/post/CosmosDBDatabaseAccountListConnectionStrings[post]
#--------------------------------------------------------------------------
result = self.mgmt_client.database_accounts.list_connection_strings(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME)
#--------------------------------------------------------------------------
# /DatabaseAccounts/post/CosmosDBDatabaseAccountListConnectionStringsMongo[post]
#--------------------------------------------------------------------------
result = self.mgmt_client.database_accounts.list_connection_strings(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME)
#--------------------------------------------------------------------------
# /DatabaseAccounts/post/CosmosDBDatabaseAccountOfflineRegion[post]
#--------------------------------------------------------------------------
[
{
"region": "North Europe"
}
]
result = self.mgmt_client.database_accounts.begin_offline_region(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, region_parameter_for_offline=BODY)
result = result.result()
#--------------------------------------------------------------------------
# /DatabaseAccounts/post/CosmosDBDatabaseAccountRegenerateKey[post]
#--------------------------------------------------------------------------
BODY = {
"key_kind": "primary"
}
result = self.mgmt_client.database_accounts.begin_regenerate_key(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, key_to_regenerate=BODY)
result = result.result()
#--------------------------------------------------------------------------
# /DatabaseAccounts/post/CosmosDBDatabaseAccountListReadOnlyKeys[post]
#--------------------------------------------------------------------------
result = self.mgmt_client.database_accounts.list_read_only_keys(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME)
#--------------------------------------------------------------------------
# /DatabaseAccounts/post/CosmosDBDatabaseAccountOnlineRegion[post]
#--------------------------------------------------------------------------
[
{
"region": "North Europe"
}
]
result = self.mgmt_client.database_accounts.begin_online_region(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, region_parameter_for_online=BODY)
result = result.result()
#--------------------------------------------------------------------------
# /DatabaseAccounts/post/CosmosDBDatabaseAccountListKeys[post]
#--------------------------------------------------------------------------
result = self.mgmt_client.database_accounts.list_keys(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME)
#--------------------------------------------------------------------------
# /DatabaseAccounts/patch/CosmosDBDatabaseAccountPatch[patch]
#--------------------------------------------------------------------------
BODY = {
"location": AZURE_LOCATION,
"tags": {
"dept": "finance"
},
"ip_rules": [
{
"ip_address_or_range": "23.43.230.120"
},
{
"ip_address_or_range": "110.12.240.0/12"
}
],
"is_virtual_network_filter_enabled": True,
"virtual_network_rules": [
{
"id": "/subscriptions/" + SUBSCRIPTION_ID + "/resourceGroups/" + RESOURCE_GROUP + "/providers/Microsoft.Network/virtualNetworks/" + VIRTUAL_NETWORK_NAME + "/subnets/" + SUBNET_NAME,
"ignore_missing_vnet_service_endpoint": False
}
],
"consistency_policy": {
"default_consistency_level": "BoundedStaleness",
"max_interval_in_seconds": "10",
"max_staleness_prefix": "200"
},
"enable_free_tier": False,
"enable_analytical_storage": True
}
result = self.mgmt_client.database_accounts.begin_update(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, update_parameters=BODY)
result = result.result()
#--------------------------------------------------------------------------
# /DatabaseAccounts/head/CosmosDBDatabaseAccountCheckNameExists[head]
#--------------------------------------------------------------------------
result = self.mgmt_client.database_accounts.check_name_exists(account_name=ACCOUNT_NAME)
#--------------------------------------------------------------------------
# /SqlResources/delete/CosmosDBSqlUserDefinedFunctionDelete[delete]
#--------------------------------------------------------------------------
result = self.mgmt_client.sql_resources.begin_delete_sql_user_defined_function(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, container_name=CONTAINER_NAME, user_defined_function_name=USER_DEFINED_FUNCTION_NAME)
result = result.result()
#--------------------------------------------------------------------------
# /SqlResources/delete/CosmosDBSqlStoredProcedureDelete[delete]
#--------------------------------------------------------------------------
result = self.mgmt_client.sql_resources.begin_delete_sql_stored_procedure(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, container_name=CONTAINER_NAME, stored_procedure_name=STORED_PROCEDURE_NAME)
result = result.result()
#--------------------------------------------------------------------------
# /SqlResources/delete/CosmosDBSqlTriggerDelete[delete]
#--------------------------------------------------------------------------
result = self.mgmt_client.sql_resources.begin_delete_sql_trigger(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, container_name=CONTAINER_NAME, trigger_name=TRIGGER_NAME)
result = result.result()
#--------------------------------------------------------------------------
# /MongoDBResources/delete/CosmosDBMongoDBCollectionDelete[delete]
#--------------------------------------------------------------------------
result = self.mgmt_client.mongo_dbresources.begin_delete_mongo_dbcollection(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, collection_name=COLLECTION_NAME)
result = result.result()
#--------------------------------------------------------------------------
# /PrivateEndpointConnections/delete/Deletes a private endpoint connection with a given name.[delete]
#--------------------------------------------------------------------------
result = self.mgmt_client.private_endpoint_connections.begin_delete(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, private_endpoint_connection_name=PRIVATE_ENDPOINT_CONNECTION_NAME)
result = result.result()
#--------------------------------------------------------------------------
# /SqlResources/delete/CosmosDBSqlContainerDelete[delete]
#--------------------------------------------------------------------------
result = self.mgmt_client.sql_resources.begin_delete_sql_container(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, container_name=CONTAINER_NAME)
result = result.result()
#--------------------------------------------------------------------------
# /CassandraResources/delete/CosmosDBCassandraTableDelete[delete]
#--------------------------------------------------------------------------
result = self.mgmt_client.cassandra_resources.begin_delete_cassandra_table(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, keyspace_name=KEYSPACE_NAME, table_name=TABLE_NAME)
result = result.result()
#--------------------------------------------------------------------------
# /GremlinResources/delete/CosmosDBGremlinGraphDelete[delete]
#--------------------------------------------------------------------------
result = self.mgmt_client.gremlin_resources.begin_delete_gremlin_graph(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME, graph_name=GRAPH_NAME)
result = result.result()
#--------------------------------------------------------------------------
# /NotebookWorkspaces/delete/CosmosDBNotebookWorkspaceDelete[delete]
#--------------------------------------------------------------------------
result = self.mgmt_client.notebook_workspaces.begin_delete(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, notebook_workspace_name=NOTEBOOK_WORKSPACE_NAME)
result = result.result()
#--------------------------------------------------------------------------
# /CassandraResources/delete/CosmosDBCassandraKeyspaceDelete[delete]
#--------------------------------------------------------------------------
result = self.mgmt_client.cassandra_resources.begin_delete_cassandra_keyspace(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, keyspace_name=KEYSPACE_NAME)
result = result.result()
#--------------------------------------------------------------------------
# /MongoDBResources/delete/CosmosDBMongoDBDatabaseDelete[delete]
#--------------------------------------------------------------------------
result = self.mgmt_client.mongo_dbresources.begin_delete_mongo_dbdatabase(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME)
result = result.result()
#--------------------------------------------------------------------------
# /GremlinResources/delete/CosmosDBGremlinDatabaseDelete[delete]
#--------------------------------------------------------------------------
result = self.mgmt_client.gremlin_resources.begin_delete_gremlin_database(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME)
result = result.result()
#--------------------------------------------------------------------------
# /SqlResources/delete/CosmosDBSqlDatabaseDelete[delete]
#--------------------------------------------------------------------------
result = self.mgmt_client.sql_resources.begin_delete_sql_database(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, database_name=DATABASE_NAME)
result = result.result()
#--------------------------------------------------------------------------
# /TableResources/delete/CosmosDBTableDelete[delete]
#--------------------------------------------------------------------------
result = self.mgmt_client.table_resources.begin_delete_table(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME, table_name=TABLE_NAME)
result = result.result()
#--------------------------------------------------------------------------
# /DatabaseAccounts/delete/CosmosDBDatabaseAccountDelete[delete]
#--------------------------------------------------------------------------
result = self.mgmt_client.database_accounts.begin_delete(resource_group_name=RESOURCE_GROUP, account_name=ACCOUNT_NAME)
result = result.result()
#------------------------------------------------------------------------------
if __name__ == '__main__':
unittest.main()
|