如何枚举所有分区并聚合结果

2023-12-06

我有一个多分区的有状态服务。我怎样才能枚举它的所有分区和聚合结果,使用服务远程处理用于客户端和服务之间的通信?


您可以使用枚举分区FabricClient:

var serviceName = new Uri("fabric:/MyApp/MyService");
using (var client = new FabricClient())
{
    var partitions = await client.QueryManager.GetPartitionListAsync(serviceName);

    foreach (var partition in partitions)
    {
        Debug.Assert(partition.PartitionInformation.Kind == ServicePartitionKind.Int64Range);
        var partitionInformation = (Int64RangePartitionInformation)partition.PartitionInformation;
        var proxy = ServiceProxy.Create<IMyService>(serviceName, new ServicePartitionKey(partitionInformation.LowKey));
        // TODO: call service
    }
}

请注意,您可能应该缓存以下结果GetPartitionListAsync因为如果不重新创建服务就无法更改服务分区(您可以只保留一个列表LowKey值)。

此外,FabricClient还应该尽可能多地共享(请参阅文档).

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

如何枚举所有分区并聚合结果 的相关文章

  • Azure Service Fabric Actors - 未处理的异常?

    现在我们的 ASF 集群正在运行 Web API 项目 无状态且面向公众 Actor 项目 大部分是易失性的 将数据保存在内存中 由某些 API 使用 我们正在尝试 Application Insights 我可以像他们的文档一样设置未处理
  • Service Fabric 微服务与 Azure 云服务/Web 应用程序集合的优势

    我有一个可以分解为多个通信服务的应用程序 我当前的实现是整体的 我想重新组织它 以便可以独立地部署 迭代和扩展各个组件 我发现使用 Azure 有两种方法可以实现此目的 Service Fabric 服务由一组通信微服务 无状态 Web A
  • 订阅 Service Fabric 群集级别事件

    我正在尝试创建一项服务 该服务将为在我的 Service Fabric 集群中运行的应用程序更新服务端点的外部列表 基本上 我需要在本地 F5 负载均衡器中复制 Azure 负载均衡器 在上个月的 Service Fabric 问答中 团队
  • Azure Service Fabric 在生产服务器上缺少 DLL:FabricCommon.dll

    我创建了一个在开发集群上运行的参与者服务 ASP NET 应用程序 通过 IIS 单独托管 连接到集群并使用参与者 这很好用 但是 当我将所有内容部署到生产环境时 ASP NET 应用程序无法连接到集群 并出现以下异常 该集群托管在本地 W
  • Service Fabric 多租户

    我们计划将 Azure Service Fabric 用于面向数据的多租户应用程序 通常有 100 多个客户 每个客户有 5 100 个用户 查看文档 我得出的结论是 最好的方法是为每个客户使用应用程序实例 而不是尝试使用配置文件来实现多租
  • 向 Service Fabric 群集中特定节点上运行的 ASP.Net Core Web API 发送请求

    我正在开发一个 Service Fabric 应用程序 在其中运行包含一堆 ASP NET Core Web API 的应用程序 现在 当我在配置了 5 个节点的本地 Service Fabric 集群上运行应用程序时 应用程序成功运行 并
  • Azure 中的 Service Fabric 群集只能通过 VPN 网关访问

    我想知道是否可以设立一个无担保的Service Fabric 群集只能通过 VPN 网关访问 而不能通过公共 Internet 我们目前有一个无担保的我们想要迁移到云中的本地集群 使用具有无法更改的公共 IP 地址的负载均衡器创建集群的新资
  • 具有 kestrel 和反向代理的 Service Fabric https 端点

    我一直在尝试按照我能找到的微软文档和各种帖子 博客上的说明在无状态 API 端点上设置 Https 它在本地运行良好 但在将其部署到我的开发服务器上后 我正在努力使其工作 Browser HTTP ERROR 504 Vm event vi
  • Kubernetes + Docker + AWS = Azure + Service Fabric 吗?

    我看到了 Kubernetes 的优势 其中包括滚动部署 自动运行状况检查监控以及在现有服务器发生故障时启动新服务器来采取行动 我也明白 Kubernetes 不仅仅适用于 Docker 所以 这带来了几个问题 当 Azure 和 Serv
  • Service-Fabric 绑定到多个端点

    是否可以绑定服务结构应用程序来侦听多个端口 基本上 我试图拥有一个面向公众的服务 它侦听 http 80 和 https 443 并将任何 http 请求重定向到 https 我创建了一个新的 ASP net Core 服务 它单独工作正常
  • Service Fabric 容器项目可以从 Docker Hub 中提取吗?

    我在 Visual Studio 中创建了一个新的 Service Fabric 容器项目 并尝试通过发布到本地集群来测试该项目 我创建了一个 Windows 容器映像 并在 Docker 中本地运行 我将镜像推送到 Docker Hub
  • 如何将 Azure 管道变量传递到 AzureResourceManagerTemplateDeployment@3 任务使用的 ARM 模板?

    我尝试在每天晚上安排的 Azure 管道中执行以下 2 个步骤 将自签名证书放入密钥库 通过 ARM 模板部署 Service Fabric 集群 并使用证书指纹和秘密 ID 作为参数 在密钥库中创建证书的第一步对我来说效果很好 impor
  • dotnetcore 中的服务结构客户端身份验证 UserPasswordCredential 不起作用

    我正在 aspnetcore dotnetcore2 0 应用程序中构建一个小型服务结构维护 但现在无法识别 UserPasswordCredential 类 从here https github com AzureAD azure act
  • 无法对安全 Service Fabric 群集的 FabricClient 进行身份验证

    我有一个安全的服务结构集群 相同的证书用作服务器证书和客户端身份验证 我无法创建FabricClient在控制台应用程序中 它允许我连接到该集群 我正在使用记录的代码片段here https learn microsoft com en u
  • 将 Service Fabric 应用程序发布到 Azure 时操作超时

    当我尝试将 Service Fabric 应用程序发布到 Azure 群集时 收到以下错误消息 3 gt Copy ServiceFabricApplicationPackage Operation timed out 3 gt At C
  • Fabric 消息太大

    我试图将 5MB 数据从服务传递给参与者 但收到错误 Fabric 消息太大 如何增加微服务之间可传输的最大大小 我看了以下内容page https github com Azure azure content blob master ar
  • 是否可以更新 Service Fabric 群集清单?

    我发现了以下API await fabricClient ClusterManager ProvisionFabricAsync null testMani xml 但还没有弄清楚在哪里存储新的manifest xml文件 按照此处列出的方
  • Service Fabric:服务之间的调用有延迟?

    我们正在开发一个由多个不同服务组成的服务结构应用程序 我们的应用程序工作方式的一个关键部分是这些服务需要大量相互调用 直到最近我们增加了应用程序的负载并发现它的速度大大减慢时 我们才遇到任何问题 经过大量调查和对各种事情进行计时后 我们发现
  • 使用 WebListener 或 OWIN 作为 Azure Service Fabric 的 API 网关

    我们在服务结构中有 4 个无状态服务微服务 它们使用 Kestrel 作为服务器 我们需要向前端公开这 4 个服务 并且对使用 WebListener 还是 OWIN 作为服务器有疑问 任何人都可以告诉谁对性能更好 我们还有用于处理令牌的身
  • 无法访问集群端点,请检查是否存在连接/防火墙/DNS 问题

    我目前正在研究云技术 在我当前的一个项目中 我在 Azure 中创建了服务结构集群 然后我尝试通过 Windows PowerShell 连接到集群 我收到错误 无法访问集群端点 请检查是否存在连接 防火墙 DNS 问题 请告诉我如何解决上

随机推荐

  • '' aria-label='Dataframe 上的 Pandas 条件返回 TypeError: 'str' 和 'int' 实例之间不支持 '>''> Dataframe 上的 Pandas 条件返回 TypeError: 'str' 和 'int' 实例之间不支持 '>'

    我正在使用 pandas 处理 DataFrame 我需要根据某些条件添加一个新列 我的数据框是 discount tax total subtotal productid 3 0 20 13 002 10 3 106 94 003 46
  • 将 .NET 刻度转换为 SQL Server DateTime

    我正在保存一个TimeSpan 来自 NET 我的数据库中的值为BIGINT在 SQL Server 中 保存 Ticks 属性 我想知道如何转换这个BIGINT值对一个DATETIMESQL Server 中的值 不是 NET 中的值 有
  • 空手道框架的 JSON 报告

    如何在使用空手道框架时生成 JSON 报告 以便我可以使用黄瓜报告插件在 JENKINS 中使用它 我的空手道版本是 空手道 apache 0 8 0 空手道 junit4 0 8 0 你真的应该阅读文档 https github com
  • 使用 if() 在 dplyr 管道链中使用 select()

    已经阅读了这两篇文章 dplyr 包可以用于条件变异吗 R 使用管道运算符时的条件评估 gt 我正在使用 Shiny input selector 如果用户选择了特定值 我希望我的数据框与其他值不同 这是一条链 filtered funne
  • 显示消息等待...当后台处理发生时

    我想将消息显示为 请稍候 直到我的 java 代码完成一些处理 page1 jsp 我的表单 其中有文本框和提交按钮 当单击提交按钮时 我正在执行表单提交并调用 page2 jsp 在页面 2 jsp 中 我从页面 1 jsp 请求参数并传
  • 如何使用 Java 发出 multipart/form-data POST 请求?

    在 Apache Commons HttpClient 版本 3 x 时代 可以进行 multipart form data POST 请求 2004年的例子 不幸的是 这在以下情况下不再可能HttpClient 4 0 版本 对于我们的核
  • 列出 R 向量中的不同值

    如何列出向量中具有重复值的不同值 我的意思是 类似于下面的 SQL 语句 SELECT DISTINCT product code FROM data 你的意思是unique R gt x c 1 1 2 3 4 4 4 R gt x 1
  • Gulp.js 任务,返回 src?

    我是 gulp 的新手 一直在研究示例设置 有些人有以下结构 gulp task XXXX function gulp src 其他人有这个 gulp task XXXX function return gulp src 我想知道有什么区别
  • 使用 getImageData、javascript、HTML5 canvas 会导致内存泄漏吗

    我正在使用 canvas 元素 并尝试在 FIrefox 4 中使用 Javascript 对图像进行一些基于像素的操作 以下代码泄漏内存 我想知道是否有人可以帮助识别泄漏的内容 使用的图像是预加载的 一旦加载 到 pImages 数组中
  • 如何使用 spring-data-couchbase 为特定 Couchbase 文档设置 TTL?

    如何使用 spring data couchbase 为特定的 couchbase 文档设置 TTL 生存时间 我知道有一种方法可以使用文档符号设置到期时间 如下所示 Document 过期 10 http docs spring io s
  • IIS FTP 7.5 扩展性(IFtpLogProvider 并将 FTP 故障记录到事件日志中)

    任何非常熟悉 IIS 中 FTP 7 5 可扩展性的人都知道我可能做错了什么吗 我在使 IFtpLogProvider 的实现正常工作以进行自定义日志记录时遇到严重困难 我想做的就是将超出静态阈值的故障记录到事件日志中 并经常进行垃圾收集
  • Python:tarfile 流

    我想从 tarball 中读取一些文件并将其保存到新的 tarball 中 这是我写的代码 archive dum 2164 archive tar Read input data input tar tarfile open archiv
  • ASP.NET:将数据从内容页传递到母版页[重复]

    这个问题在这里已经有答案了 我有一个名为headerLabel在我的母版页中 我想将其文本设置为内容页面中的标题 我该怎么做呢 在您的主页上创建一个公共属性 类似于 public string LabelValue get return t
  • 如何在openGL中纹理随机凸四边形

    好吧 为了制作一个 我的世界 模组 我开始查找 openGL 教程 我对此仍然不太了解 因为我认为在进行我想要的小修改时我真的不应该这样做 但这让我很头疼 我想要做的就是能够将纹理正确映射到不规则的凹四边形 像这样 在尝试在游戏中运行代码之
  • chrome.filesystem 保存文件而不提示位置

    我可以将文件保存在自定义位置 home Users user1 带名字file1 txt 我有这个代码 chrome fileSystem chooseEntry type openDirectory function entry chro
  • 在 VB.net 中打印外部 PDF 文档

    我知道这个问题以前曾被问过 但我的情况有点不稳定 基本上 我正在尝试打印使用以前的 Windows 窗体生成的 PDF 文件 我可以毫无问题地找到该文件 并且我使用了从 MSDN 帮助论坛找到的以下代码 Dim p As New Syste
  • 返回响应后关闭 HTTP 服务器

    我正在构建一个基于命令行的 Go 机器人 它与 Instagram API 交互 Instagram API 基于 OAuth 因此不太适合基于命令行的应用程序 为了解决这个问题 我在浏览器中打开适当的授权 URL 并使用我为重定向 URI
  • 如何正确加载数千条记录到Realm?

    我尝试使用 Realm 将大约 8000 条记录保存到磁盘中 但它阻塞了 UI 结果 我用Realm asyncOpen在后台线程中执行数据保存 当我尝试以这种方式保存大量记录时 问题是 CPU 使用率 100 如何正确加载数千条记录到Re
  • Discord.py 从机器人向机器人发送斜线命令

    我正在开发一个机器人 该机器人应该在 Discord 频道中发送斜杠命令 并且这些斜杠命令将由同一频道中的另一个机器人接收 但是 当我发送格式为斜杠命令的消息时 另一个机器人不会将其检测为命令 而是将其检测为简单的文本消息 这是我的代码 i
  • 如何枚举所有分区并聚合结果

    我有一个多分区的有状态服务 我怎样才能枚举它的所有分区和聚合结果 使用服务远程处理用于客户端和服务之间的通信 您可以使用枚举分区FabricClient var serviceName new Uri fabric MyApp MyServ