你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站,请访问 https://docs.azure.cn。
Container.GetChangeFeedIterator<T> 方法
定义
重要
一些信息与预发行产品相关,相应产品在发行之前可能会进行重大修改。 对于此处提供的信息,Microsoft 不作任何明示或暗示的担保。
此方法创建一个迭代器来使用更改源。
public abstract Microsoft.Azure.Cosmos.FeedIterator<T> GetChangeFeedIterator<T> (Microsoft.Azure.Cosmos.ChangeFeedStartFrom changeFeedStartFrom, Microsoft.Azure.Cosmos.ChangeFeedMode changeFeedMode, Microsoft.Azure.Cosmos.ChangeFeedRequestOptions changeFeedRequestOptions = default);
abstract member GetChangeFeedIterator : Microsoft.Azure.Cosmos.ChangeFeedStartFrom * Microsoft.Azure.Cosmos.ChangeFeedMode * Microsoft.Azure.Cosmos.ChangeFeedRequestOptions -> Microsoft.Azure.Cosmos.FeedIterator<'T>
Public MustOverride Function GetChangeFeedIterator(Of T) (changeFeedStartFrom As ChangeFeedStartFrom, changeFeedMode As ChangeFeedMode, Optional changeFeedRequestOptions As ChangeFeedRequestOptions = Nothing) As FeedIterator(Of T)
类型参数
- T
参数
- changeFeedStartFrom
- ChangeFeedStartFrom
从何处开始更改源。
- changeFeedMode
- ChangeFeedMode
定义使用更改源的模式。
- changeFeedRequestOptions
- ChangeFeedRequestOptions
(可选) 更改源消耗选项。
返回
用于浏览更改源的迭代器。
示例
ChangeFeedRequestOptions options = new ChangeFeedRequestOptions()
{
PageSizeHint = 10,
}
FeedIterator<MyItem> feedIterator = this.Container.GetChangeFeedIterator<MyItem>(
ChangeFeedStartFrom.Beginning(),
ChangeFeedMode.Incremental,
options);
while (feedIterator.HasMoreResults)
{
FeedResponse<MyItem> response = await feedIterator.ReadNextAsync();
if (response.StatusCode == NotModified)
{
// No new changes
// Capture response.ContinuationToken and break or sleep for some time
}
else
{
foreach (var item in response)
{
Console.WriteLine(item);
}
}
}