首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往

我如何架构轮询一个外部API,该API之前为我提供了一个长时间运行的异步操作ID来表示“已完成状态”?

要架构轮询一个外部API,可以采取以下步骤:

  1. 首先,调用该外部API并获取异步操作ID。该ID用于表示长时间运行的异步操作的“已完成状态”。
  2. 使用轮询机制来定期查询该异步操作的状态。可以使用定时器或轮询任务来定期向API发送状态查询请求。
  3. 在每次查询时,向API发送异步操作ID,并获取当前操作的状态。
  4. 根据返回的状态进行处理。如果操作仍在进行中,则继续轮询。如果操作已完成,则可以采取相应的操作,例如获取结果或执行下一步操作。
  5. 可以设置轮询的时间间隔,根据实际情况进行调整。较短的时间间隔可能会增加服务器负载,较长的时间间隔可能会延迟操作的响应时间。
  6. 为了减少对API的频繁查询,可以结合使用异步通知机制。某些API提供了异步通知功能,当操作完成时会主动通知客户端。可以注册回调URL或配置消息队列,以便在操作完成时接收到通知。

以下是轮询外部API的优势:

  • 灵活性:通过轮询机制,可以根据实际需要定制轮询间隔和处理逻辑,适应不同的业务场景。
  • 即时性:可以实时监控异步操作的状态,及时获取操作结果或执行后续操作。
  • 可控性:轮询机制可以根据实际情况进行调整,避免对API的频繁查询或延迟响应。

适用场景:

  • 长时间运行的异步任务:当需要处理长时间运行的任务时,可以通过轮询机制及时获取任务的状态和结果。
  • 异步数据处理:当需要对异步产生的数据进行处理时,可以通过轮询机制获取数据的状态和处理结果。
  • 系统集成:当需要与外部系统进行集成时,可以通过轮询机制实现系统之间的数据同步和状态更新。

推荐的腾讯云相关产品:

  • 云函数(SCF):腾讯云的无服务器计算产品,可用于定时触发轮询任务。
  • 弹性容器实例(Elastic Container Instance):腾讯云的容器实例服务,可用于轻量级容器化应用部署和管理。
  • 云消息队列 CMQ:腾讯云的消息队列服务,可用于异步通知的接收和处理。

以上是一个完善且全面的答案,详情请参考:

页面内容是否对你有帮助?
有帮助
没帮助

相关·内容

在nodejs中事件循环分析

在上一篇文章在chromev8中JavaScript事件循环分析中分析到,在chrome中js引擎是通过执行栈和事件队列形式完成js异步操作。...事件循环 当 Node.js 启动时,它将初始化事件循环机制,处理提供输入脚本,脚本可能会进行异步 API 调用、计划计时器或调用,然后开始处理事件循环。...由于这些操作任何一个都可能计划更多操作,并且轮询阶段处理新事件由内核排队,因此可以在处理轮询事件时对轮询事件进行排队。因此,长时间运行回调可以允许轮询阶段运行时间远远超过计时器阈值。...说白就是处理在此指定时间点之后可以执行提供回调,而不是用户希望执行回调的确切时间。timer回调将在指定时间过后尽早运行。...但是,如果setImmediate()回调安排,并且轮询阶段变为空闲状态,则它将结束并继续到检查阶段,而不是等待轮询事件。

4K00

使用Celery构建生产级工作流编排器

本文是在使用 Celery 一年并部署产品后总结。 将其视为您操作指南”,用于构建跨多个计算处理任务工作流编排器,了解如何对其进行通信,如何协调和部署产品。...遇到某些功能加快了长时间运行进程,这些功能侧重于 worker 轮询任务方式、指定并发性上任务分配机制、重试机制和处理故障。...这些选项提供灵活性,可以根据应用程序需要来提高性能。 prefetch multiplier:默认情况下,Workers 轮询从队列中获取其并发处理能力 4 倍任务。...对于一个长时间运行且需要从队列中立即处理任务,如果将乘数改成 1,它将只轮询能够从队列中获取并发处理能力数量任务,从而允许另一个 Workers 轮询队列中消息。...任务时间限制和处理:Celery 任务可以有自己单独时间限制,如果运行时间过长则会失败。但它也提供多种处理选项,如软时间限制和硬时间限制异常处理。

31010
  • Serverless Python 开发实战(附源码)

    从下图我们可以非常粗浅了解到一个概念调用,函数最关键概念是调用,就是事件源去调用函数,然后来完成我们一系列操作。...3、Serverless场景典型工作流程 它有涉及到这个概念,第一个概念是事件状态表示允许等待来自事件源一个事件。第二个是操作/任务状态表示这个状态下允许按照顺序或者并行运行一个函数。...从函数A中拿到结果,然后再到切换状态完成后可能会有两个结果,结果2、结果3,这是 Function 结果,其实是调取 Function 一个函数事件或者是前一个函数数值,然后再去做操作任务...第一点:长时间问题 在FaaS层,因为它就是通过事件触发,或者是有一个运行概念或者是用完即走概念,所以说不太适合在长时间运行应用。...这其实是不可否认,但是我们有一个方案,是ServerlessFramework下一个component,我们其实是有一定方案去解决长时间运行运用难点,但怎么说还是不建议大家用FaaS去做长时间

    2K41

    京东架构专家分享京东架构之路

    1.0 功能十分简单,实现一个 IM 基本功能,接入、互通消息和状态。 另外还有客服功能,就是顾客接入咨询时客服分配,按轮询方式把顾客分配给在线客服接待。...统一服务运维提供实用内部工具和库帮助开发更健壮微服务。 包括中心配置管理,流量埋点监控,数据库和缓存访问,运行时隔离,如下图所示是一个运行隔离图示: ?...细粒度微服务做到了进程间隔离,严格开发规范和工具库帮助实现异步消息和异步 HTTP 避免多个跨进程同步长调用链。...而所有这些工具和库服务都是为了两个目标: 让服务进程运行状态可见 让服务进程运行状态可被管理和改变 最后我们回到前文留下一个悬念,就是关于消息投递模型缺陷。...如何高效统一地管理这些组件,API服务化是我们答案。最好由一个训练有素团队集中管理这些组件并对外提供接口服务,将软件使用复杂性隐藏起来,调用是简单利索API

    2.8K90

    标准化API设计流程!

    通信协议 架构样式定义应用程序编程接口(API不同组件如何相互交互。因此,它们通过提供设计和构建API标准方法,确保效率、可靠性和与其他系统轻松集成。...下图显示轮询和Webhook之间比较 假设我们运行一个电子商务网站。客户端通过API网关将订单发送到订单服务,订单服务转到支付服务进行支付交易。...然后,支付服务与外部支付服务提供商(PSP)进行通信以完成交易。 ❝有两种方法可以处理与外部PSP通信。 1.短轮询 在向PSP发送支付请求之后,支付服务继续询问PSP关于支付状态。...2.Webhook 我们可以使用外部服务注册一个webhook。这意味着:当你有关于请求更新时,请在某个URL上给我回电话。当PSP完成处理后,它将调用HTTP请求更新支付状态。...通过这种方式,改变了编程范例,并且支付服务不再需要浪费资源轮询支付状态。 如果PSP不回电话怎么办?我们可以设置一个清洁工,每小时检查一次付款情况。

    13810

    一文理解Netty模型架构

    ):分发器与处理器之间联系渠道 事件处理器(event processor):实现业务逻辑,处理完成后会发出事件,触发下一步操作 可以看出,相对传统轮询模式,事件驱动有如下优点: 可扩展性好,分布式异步架构...当一个异步过程调用发出后,调用者不能立刻得到结果。实际处理这个调用部件在完成后,通过状态、通知和回调来通知调用者。...当future对象刚刚创建时,处于非完成状态,调用者可以通过返回ChannelFuture获取操作执行状态,注册监听函数来执行完成操,常见有如下操作: 通过isDone方法判断当前操作是否完成...方法注册监听器,当操作完成(isDone方法返回完成),将会通知指定监听器;如果future对象已完成,则理解通知指定监听器 例如下面的代码中绑定端口是异步操作,当绑定操作处理完,将会调用相应监听器处理逻辑...Channel Netty网络通信组件,能够用于执行网络I/O操作。 Channel为用户提供: 当前网络连接通道状态(例如是否打开?是否连接?)

    1.1K20

    一文理解Netty模型架构

    ):分发器与处理器之间联系渠道 事件处理器(event processor):实现业务逻辑,处理完成后会发出事件,触发下一步操作 可以看出,相对传统轮询模式,事件驱动有如下优点: 可扩展性好,分布式异步架构...当一个异步过程调用发出后,调用者不能立刻得到结果。实际处理这个调用部件在完成后,通过状态、通知和回调来通知调用者。...当future对象刚刚创建时,处于非完成状态,调用者可以通过返回ChannelFuture获取操作执行状态,注册监听函数来执行完成操,常见有如下操作: 通过isDone方法判断当前操作是否完成...方法注册监听器,当操作完成(isDone方法返回完成),将会通知指定监听器;如果future对象已完成,则理解通知指定监听器 例如下面的代码中绑定端口是异步操作,当绑定操作处理完,将会调用相应监听器处理逻辑...Channel Netty网络通信组件,能够用于执行网络I/O操作。 Channel为用户提供: 当前网络连接通道状态(例如是否打开?是否连接?)

    78340

    Rxjs 响应式编程-第二章:序列深入研究

    计算序列平均值也是一个聚合操作.RxJS提供实例运算符平均值,但是为了本节目的,我们想看看如何使用reduce实现它。...被封装之后Observables 当您使用包含不提供取消外部APIObservable时,Observable仍会在取消时停止发出通知,但基础API不一定会被取消。...了解我们在Observable中使用外部API详细信息非常重要。您可能认为取消序列,但底层API会继续运行并在程序中引起一些副作用。 这些错误真的很难捕捉到。...这样我们就不会重绘已经绘制过地震。 在不到20行中,我们编写了一个应用程序,定期轮询外部JSONP URL,从其内容中提取具体数据,然后过滤掉导入地震。...我们已经介绍最常见运算符转换Observables,更重要是,我们只使用Observable序列构建了一个真实世界应用程序,避免设置任何外部状态,循环或条件分支。

    4.2K20

    Netty - 回顾Netty高性能原理和框架架构解析

    异步处理 异步概念和同步相对。当一个异步过程调用发出后,调用者不能立刻得到结果。实际处理这个调用部件在完成后,通过状态、通知和回调来通知调用者。...当 Future 对象刚刚创建时,处于非完成状态,调用者可以通过返回 ChannelFuture 获取操作执行状态,注册监听函数来执行完成操作。...常见有如下操作: 1)通过 isDone 方法判断当前操作是否完成; 2)通过 isSuccess 方法判断已完成的当前操作是否成功; 3)通过 getCause 方法获取已完成的当前操作失败原因...Channel Netty 网络通信组件,能够用于执行网络 I/O 操作。 Channel 为用户提供: 1)当前网络连接通道状态(例如是否打开?是否连接?)...2)网络连接配置参数 (例如接收缓冲区大小) 3)提供异步网络 I/O 操作(如建立连接,读写,绑定端口),异步调用意味着任何 I/O 调用都将立即返回,并且不保证在调用结束时所请求 I/O 操作完成

    2K30

    所有你需要知道关于完全理解 Node.js 事件循环及其度量

    每次异步操作发生时,主线程将把工作交给事件循环线程,一旦完成,事件循环线程将通知主线程执行回调。 现实 只有一个线程执行 JavaScript 代码,事件循环也运行在这个线程上面。...误解2:异步所有内容都由线程池处理 误解 异步操作,像操作文件系统,向外发送 HTTP 请求以及与数据库通信等都是由 libuv 提供线程池处理。...现实 Libuv 默认使用四个线程创建一个线程池完成异步工作。今天操作系统已经为许多 I/O 任务提供异步接口(例子 AIO on Linux)。...没有现成 API 可以从事件循环中获取运行时指标,因此每个监控工具都提供自己指标,让我们来看看都有些什么。 记录频率 每次记录数。 记录持续时间 一个刻度时间。...高工作处理延迟表示一个繁忙/耗尽线程池。 为了测试这个指标,创建了一个使用 Sharp 模块来处理图像 express 路由。 由于图像处理开销太大,Sharp 利用线程池实现。 ?

    1.3K110

    新手入门:目前为止最透彻Netty高性能原理和框架架构解析

    异步处理】: 异步概念和同步相对。当一个异步过程调用发出后,调用者不能立刻得到结果。实际处理这个调用部件在完成后,通过状态、通知和回调来通知调用者。...当 Future 对象刚刚创建时,处于非完成状态,调用者可以通过返回 ChannelFuture 获取操作执行状态,注册监听函数来执行完成操作。...常见有如下操作: 1)通过 isDone 方法判断当前操作是否完成; 2)通过 isSuccess 方法判断已完成的当前操作是否成功; 3)通过 getCause 方法获取已完成的当前操作失败原因...【Channel】: Netty 网络通信组件,能够用于执行网络 I/O 操作。Channel 为用户提供: 1)当前网络连接通道状态(例如是否打开?是否连接?)...2)网络连接配置参数 (例如接收缓冲区大小) 3)提供异步网络 I/O 操作(如建立连接,读写,绑定端口),异步调用意味着任何 I/O 调用都将立即返回,并且不保证在调用结束时所请求 I/O 操作完成

    7K31

    基于 Asp.Net Comet 技术解析

    简单说是一种基于现有Http协议基础上轮询技术,所有会产生这种技术主要原因是Http协议是无状态所以客户端和服务端之间没办法建立起一套长时间连接。...通过Ajax技术可以实现长轮询服务器推模型,客户端和服务端之间通过不断发起长轮询即可以实现数据交互,这个过程由于是Ajax实现异步操作所以体验上会比较好,效率也很高。...一旦异步操作完成之后,则可以通过EndProcessRequest方法获得异步结果。...Asp.Net实现Comet 有技术基础那么来看看如何实现这项技术: 在客户端我们需要实现发送请求,这方面可以通过Ajax技术实现,可以通过javascript比较简单方便实现异步请求操作。...在实际运行状态下了发现会每隔10秒调用一次_connect()方法,重新发起长连接。 这样好处想应该是减少长连接在服务器上呆时间吧。

    1.5K80

    Netty权威指南_算法笔记上机指南pdf

    linux内核将所有外部设备都看作一个文件操作,对文件读写会调用内核提供命令,返回一个文件描述符。对一个socket读写也会有相应socket fd。...JDK 1.4新增个java.nio包,提供进行异步IO开发API和类库,主要类和接口如下:进行异步IO操作缓冲区ByteBuffer、管道Pipe、各种异步或同步通道Channel、实现非阻塞...JDK1.7 对NIO做了升级,被称为NIO 2.0版,主要改进三个方面如下: ①提供批量获取文件属性API。 ②提供AIO功能,支持基于文件异步IO操作和针对网络套接字异步操作。...例如长时间轮询,消耗大量服务器带宽。...netty提供基于内存池缓冲区重用机制,进行对象分配和回收。 ⑧灵活TCP参数配置能力。

    1.3K40

    n1-Kubernetes名称概念解释一览

    应用场景: 1.API-Server以 RESTful API 形式提供可以查询、修改集群状态 CRUD(Create、Read、Update、Delete)接口, 使其将这些对集群中各种资源增删改查状态存储到...2.API-Server为k8s中系统组件间提供交流平台,并且是与etcd 通信唯一组件,其他组件不会直接和 etcd 通信,而是通过 API 服务器修改集群状态。...发现 pod 被调度到本节点,它就会创建并且运行 pod 容器; 调度器为 pod 查找可用节点需要检查关键项: 节点是否满足硬件需求 节点是否耗尽资源 pod 是否配置 nodeSelector...调度器则只是给 pod 分配节点,所以需要有活跃组件确保系统真实状态 API 服务器定义期望状态收敛,工作由控制器管理器里控制器实现; k8s 内部控制工作都通过 APIServer 这一声明式数据存储进行了解耦...它第一个任务就是在 API 服务器中创建一个 Node 资源注册节点。然后需要持续监控 API 服务器是否把节点分配给 pod 然后启动 pod 容器。

    76710

    Serverless Python开发实战之极速制作情人节表白页

    从下图我们可以非常粗浅了解到一个概念调用,函数最关键概念是调用,就是事件源去调用函数,然后来完成我们一系列操作。...3、Serverless场景典型工作流程 它有涉及到这个概念,第一个概念是事件状态表示允许等待来自事件源一个事件。第二个是操作/任务状态表示这个状态下允许按照顺序或者并行运行一个函数。...从函数A中拿到结果,然后再到切换状态完成后可能会有两个结果,结果2、结果3,这是Function结果,其实是调取Function一个函数事件或者是前一个函数数值,然后再去做操作任务,最后来到...第一个就是长时间问题,在FaaS层,因为它就是通过事件触发,或者是有一个运行概念或者是用完即走概念,所以说不太适合在长时间运行应用。...这其实是不可否认,但是我们有一个方案,是Serverless Framework下一个component,我们其实是有一定方案去解决长时间运行运用难点,但怎么说还是不建议大家用FaaS去做长时间

    29740

    零成本异步 IO (下)

    Alex 和 Aaron Turon,是他们提出了这个想法——不是由 Future 调度回调函数,而是由我们去轮询 Future,所以还有另一个被称为执行器(executor)组件,它负责实际运行...这表示一个枚举(enum)结构,即一个包含变体判别式及所有可能状态联合体(union)。 ? 译者注:报告视频中幻灯片比较模糊,对其进行了重绘与翻译,下同。...上面的幻灯片尽可能直观地表示这个状态机模型。可以看到,你执行了两个 I/O 事件,所以它有这几个状态。对于每个状态它都提供所需内存空间,足够你在 I/O 事件后恢复执行。...async / await 一个版本并不是 Rust 语言一部分,而是由库像语法插件一样提供。...如果你 API 中有一些内容表明必须使用 Pin,那么你就知道它再也不会被移动,这样就你可以使用那种自引用结构体

    1K10

    C#多线程开发-线程池03

    你好,是阿辉。 正文共2608字,预计阅读时间7分钟。 前面2篇文章介绍线程基础知识和线程同步,下面我们一起认识学习下,线程池使用。...保持在线程中操作都是短暂是非常重要。不要在线程池中放入长时间运行操作,或者阻塞工作线程。 这将导致所有工作线程变得繁忙,从而无法服务用户操作。这会导致性能问题和非常难以调式错误。...BeginInvoke方法接受一个回调函数,该回调函数会在异步操作完成后会被调用,并且一个用户自定义状态会传给该回调函数。...状态通常用于区分异步调用,是一个实现IAsyncResult接口result对象。...事件表示一些通知源或当通知到达时会有所响应一系列订阅者。 这种就是基于事件异步模式(EAP),就是启动一个异步操作然后订阅给不同事件,这些事件在操作执行时会被触发。

    89920

    Elasticsearch Document Index API详解、原理与示例

    外部版本号一个最佳实践,使用源数据库中数据版本号,就不需要维护对源数据库更改所执行异步索引操作严格排序。...当使用create时,如果id文档已经存在于索引中,索引操作将会败。 OpType如下可选值: OpType.INDEX 索引,如果文档存在,覆盖,内部版本号+1。...ElasticSearch提供显示指定路由字段方法,通过routing指定路由值,索引API通过IndexRequest#routing()方法指定路由值。...除非集群中出现一个节点来承载第4个副本,否则操作将超时。...写操作响应分片部分(5.1节所示)揭示复制成功/失败分片副本数量,数据在主分片、副本之间数据最终一致性处理在《Elasticsearch Document API文档读写概要设计》写模型异常处理部分有相应处理机制

    2.9K10

    分布式系统在 Kubernetes 上进化

    此外,这些组件可以用不同语言创建,运行在混合环境上,并开发开源技术、开放标准和互操作性。相信你可以使用闭源软件构建这样系统,也可以在 AWS 和其他地方构建。...然后,如果这就是 Kubernetes 给开发者提供全部功能,那么我们如何扩展 Kubernetes 呢?以及如何使它具有更多功能?因此,想描述当今使用两种常用方法。...Knative Eventing 为我们提供一个完全声明式事件管理系统。假设我们有一些要与集成外部系统,以及一些外部事件生产者。在底部,我们将应用程序放在具有 HTTP 端点容器中。...这让想到了最初问题,微服务之后是什么? 如果我们看下架构发展历程,应用架构在很高层面上是从单体应用开始。然而微服务给我们提供如何一个单体应用拆分成独立业务域指导原则。...可能是多运行时(把它称为 Mecha 架构 [8]),在架构中你将业务逻辑放在一个容器中,而所有与基础设施相关关注点作为一个单独容器存在。它们共同代表多运行时微服务。

    1.2K20

    Serverless Python开发实战之极速制作情人节表白页

    从下图我们可以非常粗浅了解到一个概念调用,函数最关键概念是调用,就是事件源去调用函数,然后来完成我们一系列操作。...第二个是操作/任务状态表示这个状态下允许按照顺序或者并行运行一个函数。第三个是切换状态,它允许切换到多个其他状态,比方说前一个函数结果,然后触发分支,转换到不同一个状态。...从函数A中拿到结果,然后再到切换状态完成后可能会有两个结果,结果2、结果3,这是Function结果,其实是调取Function一个函数事件或者是前一个函数数值,然后再去做操作任务,最后来到...[h34knb34am.png] 4、Serverless 函数架构规范 现在我们来看一下Serverless底层FaaS函数、调用模型如何定义,包括约束。 首先看函数定义,下图表示比较清楚。...这其实是不可否认,但是我们有一个方案,是Serverless Framework下一个component,我们其实是有一定方案去解决长时间运行运用难点,但怎么说还是不建议大家用FaaS去做长时间

    2.2K20
    领券