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
|
# -------------------------------------------------------------------------
# Copyright (c) Microsoft Corporation. All rights reserved.
# Licensed under the MIT License. See LICENSE.txt in the project root for
# license information.
# -------------------------------------------------------------------------
import azure.cosmos.documents as documents
import azure.cosmos.cosmos_client as cosmos_client
import azure.cosmos.exceptions as exceptions
import azure.cosmos.partition_key as partition_key
import uuid
import config
# ----------------------------------------------------------------------------------------------------------
# Prerequisites -
#
# 1. An Azure Cosmos account -
# https:#azure.microsoft.com/en-us/documentation/articles/documentdb-create-account/
#
# 2. Microsoft Azure Cosmos PyPi package -
# https://pypi.python.org/pypi/azure-cosmos/
# ----------------------------------------------------------------------------------------------------------
# Sample - demonstrates how to consume the Change Feed and iterate on the results.
# ----------------------------------------------------------------------------------------------------------
HOST = config.settings['host']
MASTER_KEY = config.settings['master_key']
DATABASE_ID = config.settings['database_id']
CONTAINER_ID = config.settings['container_id']
def create_items(container, size):
print('Creating Items')
for i in range(1, size):
c = str(uuid.uuid4())
item_definition = {'id': 'item' + c,
'address': {'street': '1 Microsoft Way'+c,
'city': 'Redmond'+c,
'state': 'WA',
'zip code': 98052
}
}
created_item = container.create_item(body=item_definition)
def read_change_feed(container):
print('\nReading Change Feed from the beginning\n')
# For a particular Partition Key Range we can use partition_key_range_id]
# 'is_start_from_beginning = True' will read from the beginning of the history of the container
# If no is_start_from_beginning is specified, the read change feed loop will pickup the items that happen while the loop / process is active
response = container.query_items_change_feed(is_start_from_beginning=True)
for doc in response:
print(doc)
print('\nFinished reading all the change feed\n')
def run_sample():
client = cosmos_client.CosmosClient(HOST, {'masterKey': MASTER_KEY})
try:
# setup database for this sample
try:
db = client.create_database(id=DATABASE_ID)
except exceptions.CosmosResourceExistsError:
raise RuntimeError("Database with id '{}' already exists".format(DATABASE_ID))
# setup container for this sample
try:
container = db.create_container(
id=CONTAINER_ID,
partition_key=partition_key.PartitionKey(path='/address/state', kind=documents.PartitionKind.Hash)
)
print('Container with id \'{0}\' created'.format(CONTAINER_ID))
except exceptions.CosmosResourceExistsError:
raise RuntimeError("Container with id '{}' already exists".format(CONTAINER_ID))
create_items(container, 100)
read_change_feed(container)
# cleanup database after sample
try:
client.delete_database(db)
except exceptions.CosmosResourceNotFoundError:
pass
except exceptions.CosmosHttpResponseError as e:
print('\nrun_sample has caught an error. {0}'.format(e.message))
finally:
print("\nrun_sample done")
if __name__ == '__main__':
run_sample()
|
