如何使用Azure函数Cosmos DB触发器捕获更改？

Question

我有以下要求，我想从cosmosDB捕获记录，并将其推送到博客存储。

我已经用azure函数cosmos DB trigger解决了上面的问题(它将捕获对cosmos DB容器中的记录所做的任何更改)。

如何捕捉满负荷？

要求是我必须从cosmos DB容器中获取所有记录并将其推送到博客存储。

所以问题是cosmosDB触发器只有在记录有一定变化时才捕获，那么我该如何实现这个满载。

对于满载，我还创建了一个python脚本。

参考资料： https://github.com/Azure/azure-cosmos-python

参考脚本：如何使用python更新Cosmos Db中的记录？

query_data = client.QueryItems(collection_link,
                                   'SELECT * FROM ' + COSMOS_DB_COLLECTION_ID,
                                   {'enableCrossPartitionQuery': True})
    for item in query_data:
        client.ReplaceItem(item['_self'], item, options=None)

因此，我的脚本实际做的是获取所有记录，我为每个记录调用ReplaceItem，但我观察到azure函数cosmos DB触发器不会捕获所有记录的更改，它只捕获少数记录。

那么脚本有问题吗？

Answer 1

首先，我认为客户没有“查询项目”。

其次，您的文档没有更改。

你应该这样做:

url = os.environ['ACCOUNT_URI']
key = os.environ['ACCOUNT_KEY']
client = cosmos_client.CosmosClient(url, {'masterKey': key})
database_name = "testbowman"
container_name = "testbowman"
database = client.get_database_client(database_name)
container = database.get_container_client(container_name)
for item in container.query_items('SELECT * FROM c', enable_cross_partition_query=True):
    logging.info("This is Query database!" + json.dumps(item))
    item['Description'] = "!!!!!!!!!!!!!!"
    container.replace_item(item['id'],item)