Cosmos Db Change Feed未给出预期结果
Cosmos DB Change Feed是Azure Cosmos DB的一个功能，它提供了实时的、增量的、有序的数据更改通知。当Cosmos DB中的文档发生更改时，Change Feed会将这些更改作为事件流发送给订阅者，以便实时处理和响应这些更改。
Change Feed的预期结果是根据订阅者的需求而定的。通常情况下，预期结果包括以下几个方面：
- 实时数据更改通知：Change Feed会实时地将文档的更改作为事件流发送给订阅者，以便及时了解数据的变化。
- 增量数据同步：Change Feed会按照更改的顺序将文档的更改发送给订阅者，确保数据的同步性和一致性。
- 有序事件处理：Change Feed会按照更改的顺序发送事件，以便订阅者可以按照正确的顺序处理这些事件。
- 可扩展性和高可用性：Change Feed可以处理大规模的数据更改，并且具有高可用性，确保数据的可靠性和稳定性。
Cosmos DB提供了多种方式来使用Change Feed，包括使用Azure Functions、Azure Logic Apps、Azure Event Grid等。根据具体的应用场景和需求，可以选择适合的方式来处理Change Feed的事件流。
对于Cosmos DB Change Feed的具体使用和相关产品介绍，可以参考腾讯云的文档和产品页面：
请注意，以上答案仅供参考，具体的实现和推荐产品可能因应用场景和需求而有所不同。
相关·内容
1回答
是否有Azure cosmos db / Azure SQL数据库函数来订阅数据更改，如Firestore中的更改？
azure、google-cloud-firestore、azure-sql-database、azure-cosmosdb
例如，在中获取中的实时更新。
db.collection("cities").where("state", "==", "CA")
.onSnapshot((querySnapshot) => {
var cities = [];
querySnapshot.forEach((doc) => {
cities.push(doc.data().name);
});
console.log("Current cities
浏览 2提问于2021-03-26得票数 0
9回答
如何快速入门Kafka消息队列？
消息队列 CMQ 版、消息队列 CKafka 版
最近经常听到这个名词，但是不知道如何入门，我看到腾讯云也有相关的产品Ckafka产品，所以来问问~
浏览 4973提问于2018-09-14
2回答
为应用程序设置中不同的输入值执行相同的Azure函数
azure、azure-web-app-service、azure-functions、azure-application-settings
我有一个Azure函数场景如下: 1)如果产品= 123，那么使用服务总线Topic1 2)如果产品= 456，那么使用服务总线Topic2
我认为有两种方法可以解决这个问题：
选项1：具有相同的Azure函数部署2次(2个不同名称)，并且每个函数具有不同的输入/输出映射
选项2：只有一个Azure函数，但在应用程序设置中指定输入/输出映射。**根据我的理解，应用程序设置是关键的值。这是正确的吗？如果没有，如何在此参数**中指定复杂值。
最好的办法是什么？
我想的是在不同的设置下2次部署相同的Azure函数，如下所示：
Azure函数1，应用程序设置为"productid“= 12
浏览 5提问于2018-01-29得票数 0
2回答
Azure应用高可用性
azure、azure-functions、azureservicebus、high-availability、azure-eventhub
我在IoT企业应用程序中工作，在那里我们创建了美国中南部的所有资源。最近(9/4/18)我注意到，由于任何原因，美国中南部的营业时间很长。
现在，当一个完整的区域关闭时，我正试图为高可用性找到最好的解决方案。
我们正在使用下面的Azure资源。
远程数据摄取( EventHub )
Azure函数(EventHub、CosmosDB、ServicesBus触发器)
WebJob &WebJob(计划和持续)
ServiceBus (队列和主题)
应用程序洞察(应用程序日志)
存储帐户(EventHub检查点和其他数据)
Cosmos DB
VSTS (CI/CD)
对于Cosm
浏览 1提问于2018-09-19得票数 1
3回答
Azure事件商店
azure
根据我的理解，事件存储只是所有事件的数据存储。这可以是从关系数据库到NoSQL的任何东西，但是应该对存储和查询大量非关系data.So进行优化，我们可以使用以下服务在Azure中存储事件：
蓝表存储
Azure SQL Server
Azure Cosmos DB
Azure事件中心
上述服务中的哪一项是用于事件源的？
浏览 4提问于2020-08-08得票数 7
回答已采纳
2回答
在Azure Cosmos数据库中显示数据库位置
azure、azure-cosmosdb
我正在Azure Cosmos DB Geo-replication上设置POC。我希望我的示例应用程序显示从中读取数据的数据中心。这样，我就可以通过从不同的地理位置测试相同的应用程序来轻松地测试地理位置和故障转移。
知道数据中心的位置是否暴露在api中吗？
浏览 0提问于2017-09-25得票数 1
1回答
如何用Azure函数应用程序备份Azure Cosmos DB
azure、azure-functions、azure-cosmosdb
问题：
我试图为Azure Cosmos DB构建一个备份解决方案，它定期为我们提供DB转储，以防我们以编程方式损坏数据库中的数据。问题是数据工厂还不存在于德国Azure，我们不能依赖Azure的自动备份(只提供8小时)。我不想在云之外使用任何额外的应用程序。
到目前为止我所发现的：
Mongo转储流应该能够连接到我们的DB并从中读取。
我的想法是在Azure函数中使用这个npm，并将转储结果发送到blob存储。
我的问题：
如何将结果发送到blob存储区？
你能给出一个具体实施的例子吗？
浏览 0提问于2018-08-31得票数 2
回答已采纳
1回答
Azure CosmosDB -将其用作队列
message-queue、azure-cosmosdb
我在Azure Cosmos db (新的文档数据库)上做了一些阅读，注意到它允许在将数据写入数据库时执行Azure函数。
通常，我会写入服务总线，然后使用Azure函数处理消息，并将消息存储在文档db中作为历史记录。
我需要一些关于CosmoDB良好实践的帮助。
浏览 1提问于2017-10-02得票数 0
1回答
使用具有Azure函数和Cosmos数据库的Microsoft Event Hub进行数据检索
azure、azure-functions、azure-cosmosdb、azure-eventhub
我们正在开发一个使用Azure函数、事件中心、Cosmos DB、SignalR的应用程序。我们设置了Event Hub来监听来自前端的所有事件。我们使用的是CosmosDB，它将数据存储在单个集合中。当我们向集合中添加新记录时，我们希望将此信息传递给前端，以便它们只能更新新添加的记录。但我们不知道如何做到这一点，因为它是一个单一的集合，它将返回所有数据。如果它有一个SQL数据库，那么我们可以选择最近添加的记录。
我们非常感谢您的任何建议。
浏览 2提问于2018-03-17得票数 0
2回答
如何在特定阶段从蔚蓝宇宙数据库备份数据到azure blob？
node.js、azure、azure-cosmosdb、azure-blob-storage、azure-data-factory
我有Azure cosmos DB帐户，我想做的是备份数据，这是一个月前从蔚蓝宇宙数据库到azure blob存储使用我的节点应用程序。我已经为Nodejs创建了管道，并使用create管线API (使用Azure数据工厂)触发了管道。但我无法弄清楚如何使管道选择数据，这是一个月前从目前的日期。有什么建议吗？
编辑：实际上，我想每天运行API，以便它备份一个月前的数据。例如，假设我今天在cosmos DB中获得了100个条目，因此管道应该从当前日期( 30天)中选择数据，并对其进行备份，以便在任何时候我的Azure cosmos DB只有最近30天的数据，而rest则备份到Azure blob
浏览 0提问于2019-07-08得票数 0
1回答
Azure Cosmos DB变更源可以用于提供类似于RethinkDB提供的实时功能吗？
azure、azure-cosmosdb
要构建类似于RethinkDB的实时功能，高级服务器端设计在Azure中会是什么样子？
使用DocumentDB作为数据存储和变更源似乎是逻辑的起点，但是下一步是什么呢？乍一看，变更源处理器库似乎与解决这个问题相关，但是阅读使我认为它是为其他东西而设计的--分发工作负载。此外，无法查询/过滤变更源似乎是一个障碍。
下面是来自的一个示例
假设您有一个聊天应用程序，有多个客户端向不同的聊天室发送消息。您可以创建订阅发送到特定房间的消息的提要：
r.table('messages').filter( r.row('room_id').eq(ROOM_ID) ).ch
浏览 2提问于2017-11-13得票数 0
2回答
将Azure SQL数据库中的数据实时复制到Synapse
azure、azure-sql-database、analytics、azure-synapse
我有几个Azure SQL数据库在生产中，并希望将数据近乎实时地复制到Synapse SQL池中。原因是我必须从生产数据库中卸载一些分析工作，并减少生产数据库上的总体负载。
我目前在ADF中有一个管道，带有增量表和一个移动数据的翻滚窗口。这很好用，但我需要让它更接近实时。
你们中有没有人有过将数据从Azure SQL Servert近乎实时地移动到Synapse SQL池的经验？
有没有类似于Cosmos HTAP的东西？
浏览 2提问于2021-01-04得票数 2
1回答
为什么认为可用性区域不提供高可用性？
azure、cloud
我是一个新的云世界的人，当我在一个云专家上看基础讲座的时候，我试着把我的头脑弄清楚一些困惑。
我正在进行Azure讲座，它们解释了regions和availability zones之间的基本区别。
根据的说法，
可用性区域是一种高可用性产品，可以保护应用程序和数据不受数据中心故障的影响。可用性区域是Azure区域内唯一的物理位置。每个区域由一个或多个具有独立电源、冷却和网络的数据中心组成。
此外，考虑到每个可用区域都有多个数据中心，因此应该更有理由和直观地认为，与regions相比，availability zones提供了Fault Tolerance和High Availabil
浏览 5提问于2021-05-02得票数 0
回答已采纳
1回答
对CosmosDB change提要使用多个使用者
azure-cosmosdb、azure-cosmosdb-sqlapi
我正在尝试使用cosmos db change feed (我指的是https://docs.microsoft.com/en-us/azure/cosmos-db/change-feed-processor和https://github.com/Azure/azure-cosmos-dotnet-v2/tree/master/samples/code-samples/ChangeFeedProcessorV2)。 当我启动一个消费者的多个实例时，观察者似乎只看到一个分区键范围。我只看到一条消息- Observer opened for partition Key Range 0，它开始接收
浏览 6提问于2019-01-10得票数 2
回答已采纳
1回答
Cosmos DB中的变更数据捕获
azure-cosmosdb、azure-cosmosdb-sqlapi
我希望捕获Cosmos DB(JSON文档)中的更改数据使用计划作业，通过azure函数或其他方式，而不影响数据库的在线性能，因为web应用程序/移动应用程序正在使用API调用读取和写入Cosmos DB中的数据。我想要用于离线ETL和分析目的的数据，就像oracle提供离线重做日志文件的方式一样。
浏览 14提问于2020-01-19得票数 1
2回答
使用什么Azure消息服务？
azure、azureservicebus、azure-eventhub
我有一个特定的案例，我想解决使用Azure消息服务，但我不确定使用哪一个。有7种选择，我想我已经缩小到了2种选择。
Azure服务总线主题
Azure活动中心
我将尝试用下面的图表解释我的需求。请记住，这只是一个虚构的场景，只是为了说明我想要什么。
用户更新产品。HTTP请求被发送到MVC应用程序。
MVC应用程序在总线上放置一个UpdateProductCommand(什么Azure总线？)
在Azure内部，它是否是Azure函数，还是其他什么，命令必须被处理。
在命令处理程序中，我希望发布一个事件，告诉所有侦听方某个特定任务已经处理。
所以P
浏览 4提问于2020-10-19得票数 1
回答已采纳
1回答
事件源和CQRS聚合
azure-functions、azure-cosmosdb、cqrs、event-sourcing、materialized-views
为了处理大量的遥测数据并仍然能够对数据执行快速查询，我采用了使用Azure函数和Azure Cosmos DB的事件源/ CQRS模式。
在我的架构中，入站遥测流存储在作为事件存储的Cosmos DB集合中。
为了创建原始遥测数据的物化视图，我在Cosmos DB触发器中使用了另一个Azure函数，它会激活存储在我的事件存储区中的所有新文档，对这些文档执行转换。
这在每个文档的基础上很容易处理。当我需要引用其他文档来计算我的物化视图时，就会遇到棘手的问题。
例如，当接收到的遥测事件包含相对计数器值(例如在特定操作中使用的能量)时。在我的物化观点中，我希望有一个包含所有能源消耗总量的文档。
现在
浏览 0提问于2018-06-17得票数 2
回答已采纳
2回答
从NiFi发布到Azure Cosmos Db
azure-cosmosdb、apache-nifi
我为我的文档创建了Azure CosmosDb数据库和容器。我使用NiFi作为主要的数据摄取工具，并希望为我的容器提供来自NiFi流文件的文档。有没有人可以分享一下从NiFi向Azure Cosmos Db发布流文件内容的方法？
提前感谢
更新(2019.05.26)：最后我使用了Python script，并从NiFi调用它来发布消息。我传递了一条消息作为参数。我选择python的原因是因为它在微软官方网站上有一些示例，其中包含所有必需的连接设置和库，因此很容易连接到Cosmos。我尝试了Mongo组件，但无法连接到Azure (安全配置不起作用)，并没有用得太远，因为Python脚本工作得
浏览 5提问于2018-12-09得票数 1
1回答
Cosmos DB附件限制和备用附件位置
c#、azure、azure-cosmosdb
我们正在将核心产品的数据存储转移到Cosmos DB。对于文档，它工作得很好，但我很难找到附件所需的信息。
我可以使用C#代码中的附件使用Microsoft.Azure.DocumentDB NuGet打包v1.19.1成功地完成我想要的任何事情。
根据我能找到的信息，对于一个帐户中的所有附件，附件的总数限制在2GB以内。这是非常有限的。在这里发现的信息：
它指出：
Azure Cosmos DB允许您使用Azure Cosmos DB (每个帐户最多2GB)或您自己的远程媒体存储二进制blobs/媒体。
这似乎意味着您可以创建指向存储在其他地方的资源的附件。也许是在CDN上。但是，
浏览 2提问于2018-01-05得票数 1
回答已采纳
1回答
是否有相当于Firebase客户端的Azure数据库能够侦听数据库更改？
firebase、nosql、azure-sql-database、azure-cosmosdb
Firebase的实时数据库SDK具有内置的回调方法，允许客户端侦听数据库更改。(例如，根据)
Azure在SQL或DocumentDB产品中有类似的功能吗？若否，原因为何？使用Azure实现此功能的最佳方法是什么？
谢谢。
编辑上下文:我正在使用Xamarin构建一个跨平台的移动应用程序。
浏览 1提问于2016-12-06得票数 15
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
活动推荐
腾讯云开发者
