队列和api嵌套公牛分离进程
队列和API嵌套公牛分离进程是一种常见的云计算架构模式，用于实现高可用性、可扩展性和异步处理的系统。下面是对这个问答内容的完善和全面的答案：
队列（Queue）是一种数据结构，用于存储和管理待处理的任务或消息。它遵循先进先出（FIFO）的原则，即最先进入队列的任务会最先被处理。队列可以用于解耦系统的不同组件，将任务的生产者和消费者解耦，从而实现异步处理和提高系统的可靠性。
API（Application Programming Interface）是一组定义了软件组件之间交互的规范和接口。API嵌套是指在一个API调用中嵌套另一个API调用，以实现复杂的业务逻辑或数据处理。
公牛（Bull）是一个基于Node.js的可靠的队列和作业处理库。它提供了简单易用的API，用于创建和管理队列，以及定义和处理作业。公牛可以与各种后端存储（如Redis）结合使用，以实现持久化的队列和作业处理。
分离进程是指将系统的不同组件或任务分配给不同的进程来执行，以提高系统的并发性和性能。通过将任务分离到独立的进程中，可以实现任务的并行处理，从而提高系统的吞吐量和响应速度。
队列和API嵌套公牛分离进程的应用场景包括但不限于：
- 异步任务处理：通过将任务放入队列中，系统可以异步处理任务，提高系统的响应速度和可靠性。例如，处理用户上传的大文件、发送电子邮件、生成报表等任务可以放入队列中异步处理。
- 批量处理：将需要批量处理的任务放入队列中，通过分离进程并行处理任务，可以提高处理速度和效率。例如，批量导入数据、批量处理图像、批量发送通知等任务可以使用队列和分离进程来实现。
- 任务调度：通过队列和分离进程，可以实现任务的调度和优先级管理。例如，将不同优先级的任务放入不同的队列中，通过分离进程按照优先级顺序处理任务，可以灵活控制任务的执行顺序和资源分配。
腾讯云提供了一系列与队列和任务处理相关的产品和服务，包括：
- 云消息队列（CMQ）：腾讯云的消息队列服务，提供高可靠、高可用的消息传递能力，支持消息的发布和订阅、延时消息、顺序消息等功能。详情请参考：云消息队列（CMQ）
- 弹性消息队列（EMQ）：腾讯云的分布式消息队列服务，具备高吞吐量、低延迟、高可靠性的特点，适用于大规模数据流处理和实时消息推送等场景。详情请参考：弹性消息队列（EMQ）
- 弹性MapReduce（EMR）：腾讯云的大数据处理平台，支持将任务分离到不同的节点上并行处理，适用于大规模数据处理和分析。详情请参考：弹性MapReduce（EMR）
通过使用腾讯云的队列和任务处理产品，可以轻松构建高可用、可扩展和异步处理的系统，提高系统的性能和可靠性。
相关·内容
1回答
当一个人被困在1+小时(通常需要2分钟来运行)时，我有一堆工作要排队，但没有失败。我无法使用我使用的公牛竞技场UI从活动状态中删除作业，所以我在Redis中删除了活动作业的键。
这删除了被阻塞的活动作业，但现在队列没有从等待列表中提取任何作业。
有什么想法吗？对如何修复它有想法吗？
浏览 5提问于2020-04-29得票数 10
2回答
如果我所理解的是正确的，处理后台任务是释放cpu绑定任务的主线程的一个好方法。
我不明白的是，像公牛或kue这样的系统使用什么来从主线程中运行任务。
他们用线吗？它们是否需要整个节点进程分叉？它们会产生子进程吗？
浏览 8提问于2016-04-13得票数 1
回答已采纳
1回答
有一个工作队列有什么好处？
、、、、
我目前正在构建一个API，用于向用户发送事务性电子邮件。我是用工作队列来做这件事的，特别是公牛。在发展过程中，我想到了一些事情；这些工作实际上是在哪里执行的？目前，我通过bull将这些作业发送到计算机上码头容器中运行的redis数据库。我的第一个想法是这些作业在redis容器中运行，但我认为这不是真的，因为redis容器没有运行NodeJS，这正是我的API所使用的。
我认为这些作业实际上是在创建它们的同一台机器上执行的。但是，如果是这样的话，有一个工作队列有什么好处呢？我认为有一个作业队列的目的是将任务委托给其他任务，这样就不会通过发送所有这些电子邮件来减缓API的速度。据我所知，现在所发生
浏览 0提问于2020-06-10得票数 0
回答已采纳
2回答
我有一个应用程序对另一个系统进行API调用，它使用Bull和Redis将这些API调用排在队列中。
然而，它偶尔会被大量API调用所困扰，或者某些东西停止正常工作，我希望用户可以通过一种简单的方法来检查系统是否只是“忙”。(否则，如果他们执行了一些操作，10分钟后还没有完成，他们会继续尝试，然后我们会得到更多的条目(在某些情况下，数据问题，他们已经发布了重复的部分，等等)。
对于队列中成功的API调用，下面是一个“键”的样子：
HSET "bull:webApi:4822" "timestamp" "1639085540683"
HSET
浏览 8提问于2021-12-09得票数 0
2回答
我正在使用公牛队列来处理作业。
假设当我重新启动我的dev服务器时，一个作业正在以active状态运行。当辅助脚本再次启动时，进程仍被设置为队列中的active，因此公牛决定再次启动辅助进程。
这很快就会造成破坏，因为脚本在开发过程中经常会重新启动，因此许多进程最终会运行并造成混乱。我只想在服务器启动时不要重启这些作业。
我尝试过的事情：
创建作业时设置using ()Writing (也尝试0) 设置attempts: 1以删除活动作业(抛出错误:丢失作业锁xx失败)：
let active_jobs = await queue.getJobs(['active'])
浏览 2提问于2020-09-29得票数 1
回答已采纳
我需要传递命令行参数、参数或execargv，这些参数应该在进程参数中出现，同时为子进程加载环境，该子进程将由公牛启动，用于处理作业。
有可能吗？如果是的话，有什么办法吗？
我可以识别用于公牛使用的子进程，其中包含/bull/lib/process，但是我想将自定义的param传递给节点进程。
浏览 6提问于2021-12-27得票数 0
1回答
目前，我们在数据库中有25k+用户。所有用户都订阅了一个公共主题All。
我在public_html中有两个目录。首先是内置在代码点火器中的API。此API用于为所有adnroid和iOS设备提供数据。
第二个目录是在Laravel中构建的管理面板。我们使用它上传数据，也发送通知给防火墙主题。
API和Admin共享相同的数据库。
如果我们发送通知给没有被很多用户订阅的主题，那么就没有问题了。
但是，如果我将通知发送到有大量用户的主题，则会在后端引起问题。
API停止响应，或者有时响应时间过长。
有时管理面板也会停止响应。
我很困惑，因为所有的事情都是由火力基地处理的。我只做了一个API调用。
浏览 0提问于2019-10-10得票数 0
我有一个公牛队列运行冗长的视频上传作业，这可能需要任何时间从<1分钟至多分钟。
作业在默认的30秒后停止运行，所以我将超时时间增加到几分钟，但这一点并没有得到遵守。如果我将超时设置为10 is，它将立即停止，因此它将考虑超时。
Job {
opts: {
attempts: 1,
timeout: 600000,
delay: 0,
timestamp: 1634753060062,
backoff: undefined
},
...
}
尽管超时，我正在接收一个stalled事件，并且作业再次开始
浏览 8提问于2021-10-20得票数 2
1回答
芹菜文档部分建议，具有多个“步骤”的任务应该划分为子任务，以便更有效地并行化。然后它提到(当然)将有更多的消息传递开销，因此划分为子任务可能不值得开销。
在我的例子中，我的总体任务是从第三方API检索一个小图像(150px X 115px)，然后通过HTTP上传到我站点的REST API。我可以将其实现为一个单独的任务，也可以将检索图像的步骤划分为两个单独的任务。如果我使用单独的任务，我假设我将不得不将图像作为消息的一部分传递给第二个任务。
我的问题是，在这种情况下，哪种方法应该更好，我如何测量性能才能确定？
浏览 0提问于2012-03-29得票数 1
回答已采纳
我使用NestJS实现工作人员，使用。
根据，工作人员和服务器(将)都在同一个“进程”中运行，但是我希望在单独的进程中运行工作人员，以便而不是阻塞主事件循环。
我认为它被称为“在一个单独的二进制文件中运行一个任务”或其他什么。
无论如何，我试着搜索它，查看了NestJS的文档，但是找不到类似的东西。
换句话说，++：
我有一个主项目(我当前的)，我想要在一个单独的进程(独立的应用程序)中创建工作人员，并且希望连接我当前的主项目和工作人员。我在文件里也找不到。
我应该在哪个模块中实例化公牛的实例？我假设我将把我的producer保留在我的主模块中，consumer保留在我的worker模块中。
浏览 5提问于2021-12-05得票数 4
回答已采纳
1回答
这似乎是一个非常天真的问题，但在微型服务方面没有多少经验。我的问题是，我们能否在message queue worker和API之间共享会话？
为什么？
需要实现一个openID Connect authentication，它将由我们的工作人员触发，但在身份验证之后，授权服务器将令牌集返回到我们的callback API end-point(在身份验证过程中注册)，并且这个端点需要一些参数(用于启动auth流，包括nonce、state和code_validation)来获取令牌。
这组变量在worker和API端点中都应该是相同的.
如果这是不可能的请分享解决方案，谢谢。
浏览 6提问于2022-10-15得票数 0
1回答
我已经配置了我的公牛并创建了一个队列。
import * as Queue from 'bull';
var emailQueue = new Queue('emails', {redis: {port: 6379, host: '127.0.0.1'}});
emailQueue.process(function(job, done){
done();
});
setInterval(function() {
emailQueue.add({from: 'someone@email.com'}, {
浏览 10提问于2019-08-13得票数 2
回答已采纳
我正在用nestjs开发一个应用程序，它在公牛中管理队列。我有一个队列希望在特定时间发送通知(从db读取)。我如何实现这一点？
浏览 7提问于2022-04-14得票数 0
回答已采纳
我想知道如何通过Queue/Bull在我的函数'myCustomMethod‘中运行代码。这样做对吗？
./models/Sport.js
export async function myCustomMethod(type, req)
{
console.log("This method should be executed via the Queue / Bull");
let computationResult = true;
return computationResult;
}
cronCustomFile.js
import { myC
浏览 0提问于2019-03-19得票数 2
1回答
背景
我计划做一个调度程序，每分钟运行一次。无论何时运行，都会给出不同的目标数据，每次可能需要大约90秒。
我的计划
这一过程类似于：
multiple producers(threads) :
1. get data from some API
2. using data from 1. parse given data
3. put it into a common queue
↓
common queue
↓
multiple consumers(threads) :
1. get data from the queue
2. call some API
3. then insert
浏览 2提问于2021-10-15得票数 0
回答已采纳
1回答
我正在使用 python库生成4个对象，以并行化一个cpu密集型任务。任务(来自这个伟大的的灵感和代码)是计算列表中每个整数的素因子。
main.py:
import random
import multiprocessing
import sys
num_inputs = 4000
num_procs = 4
proc_inputs = num_inputs/num_procs
input_list = [int(1000*random.random()) for i in xrange(num_inputs)]
output_queue = multiprocessing.Qu
浏览 0提问于2017-08-29得票数 4
回答已采纳
1回答
我在一个 API服务器中使用NodeJS。我这样称呼它：
const { fork } = require('child_process');
const dequeuingChild = fork('dequeue-child.js', null, {stdio: 'inherit', detached: false});
...
// inside some function
dequeuingChild.send({ action: ACTION.DEQUEUE }); // btw is this .send() and count
浏览 4提问于2021-03-20得票数 0
1回答
当我向作为使用者连接的同一个队列发送回复消息时，我的使用者立即尝试再次使用该消息。但如何在没有进一步消费的情况下将其作为回复发送呢？
onMessage(...){
byte[] arr = SerializationUtils.serialize(res);
//compute result message
Message resMessage = new Message(arr, composeMessageProperties(null));
message.getMessageProperties().setReplyTo("th
浏览 3提问于2016-05-24得票数 0
回答已采纳
2回答
使用公牛竞技场："^3.2.2“版本。在启动竞技场仪表板时面对这一错误
TypeError:从3.0.0开始，公牛竞技场要求将队列构造函数提供给竞技场
我尝试使用队列实例作为参数，而不是队列名称，但没有成功。
源代码：
import Arena from "bull-arena";
import Bull from "bull";
const queuesConfig = [];
for (const queue in queues) {
queuesConfig.push({
name: queues[queue],
ho
浏览 10提问于2020-08-27得票数 2
回答已采纳
1回答
我使用库来设置一个处理队列，当我对现有队列使用process方法时，我会得到一个警告，因为这个方法返回一个承诺。我注意到公牛的文档忽略了这个返回值，我想知道忽略这种承诺是否安全。
其他一些小问题，如果这个函数失败了，我还能期待什么？如果我需要等待它完成，这将导致问题，因为我将不得不等待结果在任何地方，有什么办法来防止这种情况？
浏览 3提问于2020-09-22得票数 3
回答已采纳
1回答
我正在开发一个多用户应用程序，其中用户与UI交互并提交执行请求(ER)。每个用户可以一个接一个地提交多个ERs，多个用户可以同时提交ERs。每个ER将花费大约3-5小时来完成，并使用一个或多个核心来执行。用户在ER完成后通过电子邮件被告知，他们可以再次登录查看分析的结果。
我将ERs写入PostgreSQL数据库，并使用NodeJS服务器作为执行管理器。NodeJS流程的任务是执行形成用户提交的ER的一组任务。目前，我使用数据库触发器在NodeJS流程中生成通知和“监视”通知(受此来源启发)。
相关代码如下：
pgClient.on('notification', as
浏览 0提问于2019-09-24得票数 1
1回答
我目前在我的网站上有一个div，每隔6秒左右就会淡入淡出一次，里面有不同的信息。现在，以前我只是在单独的div中硬编码，然后让它们彼此淡入淡出。
但这似乎有点草率，特别是在数据将不断更新的情况下，因此我制作了一个XML文档，我可以根据自己的喜好轻松地进行更新。
我面临的问题是，我不确定如何使用jQuery加载XML文档，选择第一个项目，等待6秒，加载第二个项目( -> second item )？
到目前为止，我已经有了这个。
function load_news(){
$(".news").html("");
$.ajax({
浏览 0提问于2012-11-01得票数 1
1回答
我在我的nusoap服务中注册了以下操作：
$server->register(
'testfunction',
array('value' => 'xsd:string'),
array( ),
'urn:test_services',
'urn:test_services#testfunction'
);
...and函数本身：
function testfunction($value)
{
// do some
浏览 0提问于2014-09-17得票数 0
回答已采纳
1回答
对不起，我不能在这里张贴专有代码。基本上，它是一个Mac应用程序。这些代码没有被正确地设计成使用异步概念。所有的东西都是在主线程上处理的，不可能在一夜之间改变设计。因此，我不想加入dispatch_async(…)解决方案。
问题的背景是:我有一个在主线程上运行的耗时的任务。在处理任务时，我尝试根据任务的完成百分比(从0%到100%)更新/重新绘制进度条(NSProgressIndicator)。但是，由于任务在主线程上运行，主线程被阻塞，事件队列中的任何更新/重绘事件都必须等待主线程有机会查看它，因此在任务执行期间进度条根本不被更新/重新绘制。
我正在考虑的解决方案是创建另一个处理进度条绘图
浏览 3提问于2020-11-23得票数 1
回答已采纳
我有一个用例来创建一个服务，它使用消息队列中的消息，处理它们，将它们存储在DB中，并通过API公开处理的结果。因此，我将要创建的服务必须同时具有API和侦听事件。
我想澄清一下，这是否是微服务体系结构中的反模式，应该避免。如果我要避免这种情况，我还有什么选择呢？
PS:我联系了这里的专业人士，因为我找不到合适的答案谷歌搜索。
浏览 0提问于2022-05-26得票数 2
1回答
我有一个带有端点的Flaks API。我使用多进程与我的程序并行运行它。Tkinter是从window.mainloop()开始的。我把他们都分成了他们自己的类(我不知道这是否影响到smth)。
现在，我想更改tkinter标签上标签的文本。我正在使用mylabel.config(text="myText")，并希望从我的API调用它(像这样的函数：)
myEndpoint(self, newStatus:str):
self.mylabel.config(text=newStatus)
return newStatus
当API进程运行我的函数时，我能做些什么
浏览 3提问于2021-11-09得票数 0
回答已采纳
2回答
我在IIS7和.NET 4.0上。我的理解是，IIS接收请求并将它们传递给ASP.NET工作线程。如果所有线程都在使用中，则请求进入队列，并在线程可用时进行处理。如果队列超过一定大小，所有新请求都会得到503，直到队列中再次有空间为止。
是否有办法优先处理排队请求的顺序？例如，我有消费者流量和基础设施流量到达同一台服务器。如果没有可用的线程，我希望先处理使用者请求，即使它们是在基础结构请求之后到达的。基本上，我想用优先级队列替换请求队列。这在IIS中有可能吗？
浏览 0提问于2012-03-27得票数 4
回答已采纳
1回答
我目前有一个API运行，它将一个摄取作业委托给一个简短的轮询bash脚本。我不知道使用类似于strongMQ的本地适配器是否会比短轮询实现消耗更少的资源。
如果消息队列比短轮询更少资源密集型，那么考虑到消息队列的实现是一个单独运行的微服务，这又是一个运行在操作系统上的节点进程或“集群”，那么这到底有什么可能呢？
浏览 2提问于2015-11-01得票数 0
回答已采纳
我的程序使用系统msgqueue作为ipc .my代码：
key = 0x0000ed79;
if( ( id=msgget(key,0666|IPC_CREAT)) <= 0 )
return false ;
else return true
问题是：
每次机器重新启动时，都会使用相同的键自动生成msgqueue，但其id为0，因此我必须对其进行ipcrm；
为什么我不能使用id为0的msgqueue？下面是手册页中msgget api返回值的描述，它的id为0似乎并不不正确：
如果成功，返回值将是消息队列标识符(非负整
浏览 2提问于2013-12-14得票数 0
我有以下问题：
我有两个不同的类；我们称它们为interface和worker。该接口应该接受来自外部的请求，并将它们多路复用给几个工作人员。
与我所发现的几乎每一个例子相反，我有几个特点：
不应该为每个请求重新创建工人。
工作人员是不同的；对workers[0]的请求不能由workers[1]回答。这种多路复用是在interface中完成的。
我有许多类似于函数的调用，它们很难通过事件或简单的队列来建模。
有几个不同的请求，这将使每个请求都很难有一个队列。
例如，假设每个工作人员都存储一个整数(假设该工作人员收到的呼叫数)。在非并行处理中，我会使用这样的方法：
cla
浏览 3提问于2015-08-22得票数 1
1回答
创建简单队列契约框架的最佳实践
、、、、
我们正在使用运行在Windows嵌入式7.0上的.net CompactFramework3.5创建一个应用程序。这个应用程序从我们不同的车辆收集不同的数据，并将它们发送回我们的服务器。
我们面临的问题是失去联系，这种情况经常发生，因为接待处有时很糟糕(隧道、树林等)。
如果连接丢失了大约15分钟，那么很多数据都无法到达服务器。现在的问题是，我们应该如何处理这些数据？使用现有的队列框架之一？创造我们自己的？
有些我们需要的东西或者是伟大的东西：
队列应该是持久的，因此如果设备重新启动，数据就不会丢失。
我们的服务器目前正在运行ASP.NET WebApi，所以如果可以使用它，那就太好了
浏览 1提问于2015-11-28得票数 0
回答已采纳
1回答
我基本上需要把我的想法放在我的游戏，即牛和公牛。我的主屏幕截图如下所示：
现在，我想要做的是，当我单击submit按钮时，在输入一个有效的数字之后，母牛和公牛数量的结果(例如"2母牛0公牛“)应该显示在表格中的一个新行中，该行将放置在Submit按钮的正下方。
现在，每当我在自动输入另一个有效数字后单击submit按钮时，应该会在同一个表中创建一个新行。此行应该包含母牛和公牛的当前结果，依此类推。示例：
浏览 0提问于2012-05-06得票数 0
回答已采纳
多亏了HnwdHost，我正在开发一个嵌入了Win32应用程序(Unity window)的WPF应用程序。
出于性能原因，我们必须将unity窗口的帧率设置为30 FPS。但是，当WPF应用程序的其他用户控件尝试显示动画时，这些动画并不流畅(例如，当我尝试快速高亮显示几个按钮时，高亮显示需要时间来跟随我的鼠标按钮)。如果我将Unity窗口的帧率设置为500，就不会再有任何问题。
这就是我分析这种情况的方法:在动画过程中，WPF GUI似乎试图刷新它的所有控件。然而，由于Unity host (HnwdHost)的帧率将变慢，刷新它需要很长时间，所有其他控件似乎都在等待。
那么，你知道是否有一
浏览 5提问于2018-09-14得票数 0
1回答
根据下面的教程()，我想出了以下脚本来调度Lumen应用程序中的乔布斯：
namespace App\Console;
use App\Jobs\ClearAccessLog;
use Illuminate\Console\Scheduling\Schedule;
use Laravel\Lumen\Console\Kernel as ConsoleKernel;
use App\Jobs\Special\DeleteCache;
use App\Jobs\Special\FetchRemoteArticles;
use App\Jobs\Special\FetchUpdateCatego
浏览 3提问于2017-12-12得票数 1
回答已采纳
我使用Node js来创建REST API。
在我的场景中，我有两个API。
API 1 -->必须获取10,000条记录并进行迭代以修改某些数据
API 2:简单的get方法。
当我打开post man并点击第一个API和第二个API时，因为Node JS是单线程的，这导致第二个API获得响应的速度较慢。
我的期望是:即使第一个API获得了时间，它也不应该在很长时间内成为第二个API。
从Node JS文档中，我发现了集群的概念。，所以我实现了集群，它创建了4个服务器实例。现在我在一个选项卡中点击API 1，在第二个选项卡中点击API 2，它工作得很好。但是当我在4个选项卡中打开API
浏览 0提问于2016-12-12得票数 1
1回答
我正在构建一个在线服务，可以制作网页截图，并将其像图像一样返回给用户。它的工作原理：
1)我为X服务器创建了虚拟框架缓冲区-为了进一步避免创建真正的窗口
2)在环境变量中注意显示是如何使用的
3)创建子进程(否则前一点不会生效)
4)在子进程中创建webkit.WebView()，“显示”窗口并加载网页。
5)当我收到关于页面已完全加载的通知-我制作屏幕截图并将其保存到文件(它只是在这一步的项目，也-如何返回到用户的浏览器？我知道Content type: image/png，但是- gtk.gdk.Pixbuf.save(stdout_file_name)？)
所以！问题！！如果我从控制台p
浏览 1提问于2012-08-24得票数 0
回答已采纳
1回答
我正在使用resque来后台处理两种类型的作业：
(1) 3rd-party API requests
(2) DB query and insert
虽然这两个作业可以并行处理，但每种作业类型本身只能按串行顺序处理。例如，DB操作需要按串行顺序进行，但可以与第三方API请求并行执行。
我正在考虑使用以下方法之一来执行此操作：
(1) Having two queues with one queue handling only API requests and the other queue
handling only db queries. Each queue will have it
浏览 0提问于2016-11-11得票数 0
5回答
我正在使用Facebook SDK在时间线上发布一些事情。问题是，API请求通常需要2-3秒，这会减慢我的网站速度，特别是因为我有很多ajax请求。
有没有办法把一部分PHP代码派生到后台？我希望所有的全局、会话等都保持不变。
浏览 0提问于2012-06-16得票数 0
2回答
我正在建立一个服务，其中每个用户将能够有一个长期运行的任务(想想网络刮板)。Express API将用于管理用户和启动进程。 我最初的计划是有一个能够旋转子进程的API，这对于少数用户来说是很好的。在某个点之后，服务器将达到容量，我不确定在这一点上我能做什么。
浏览 20提问于2019-09-01得票数 0
回答已采纳
芹菜会将任务发送给空闲的工人。
我有一个任务将每5秒运行一次，我希望这个任务只发送给一个指定的worker。
其他任务可以共享剩余的工作人员
芹菜能做到吗？？
我想知道这个参数是什么：CELERY_TASK_RESULT_EXPIRES
这是否意味着该任务将不会发送到队列中的worker？
或者，如果运行时间太长，它会停止任务吗？
浏览 0提问于2015-12-26得票数 8
1回答
处理数据流上的日志记录
、、、、
我有一个EC2实例，它使用事件发射器来处理数据。例如。
stream.on('new event', function doSomething(event){ do more stuff...})
这个数据流可能每秒有数万个事件，我想以一种高效的方式记录这些事件的处理。换句话说，每次新事件出现时，我都不愿意发送日志条目。
因此，我想我应该批量发送日志。例如。
let logArray = [];
function sendToLogs(logs) {\** send stuff *\}
stream.on('new event', function doSom
浏览 1提问于2017-01-08得票数 2
回答已采纳
1回答
如何确定进程是否具有响应性GUI，或者更确切地说，它是后台应用程序？可能有一些必要的API函数调用吗？
(答案不一定要涉及API调用)
浏览 5提问于2015-07-11得票数 0
回答已采纳
4回答
使用Linux消息队列
、、、
我必须创建单个服务器进程A和多个客户端进程(Es)。所有用户都应该使用Linux消息队列进行数据传递。信息将向两个方向流动。同时，多个客户端进程(Es)也可能已注册到服务器进程A。
目前，我只使用一个命名消息队列，它由Server Process A创建和打开，并由客户端进程(Es)使用/打开(仅)。这适用于两个流程场景(即一个服务器进程A和一个客户机进程B)，但不适用于多个客户端进程(Es)和一个服务器进程。
我在这里面临的问题是设计/逻辑。如何从其他客户端进程(Es)解除服务器进程A上的多路复用消息，以及从服务器进程A返回到相应的客户端进程，或者可能它可以发送回所有客户端进程(Es)，但必
浏览 3提问于2013-04-23得票数 2
回答已采纳
1回答
我使用Sails js (节点js框架)，并在、Heroku、和本地上运行它。
API函数从外部文件中读取数据，并执行可能需要数小时的长时间计算。
我担心的是，几分钟后，它会带着超时返回。
我有两个问题：
如何控制HTTP请求/响应超时(这里我真正需要控制什么？)
HTTP请求是否被认为是该目标的最佳实践？还是应该使用套接字IO？(嗯，我对Socket IO没有经验，也不确定我是不是在胡说八道)。
浏览 2提问于2015-01-14得票数 0
回答已采纳
1回答
我有以下脚本从api导入原始图像：
let importImages = function (meal,accessToken) {
let imagesData = meal.afbeeldingenInfo;
let mealFolder = 'client/import/meal-'+meal.maaltijdId;
ensureExists(mealFolder, 0o755, function(err) {
if (err) {
winston.error('Not able to create a folder : %s&
浏览 0提问于2018-04-23得票数 0
回答已采纳
1回答
我正在编写一段代码，它将能够访问多个web API(具有告知机器状态的API的硬件)，当一个正在等待另一个等待响应时不会阻塞，一旦其中一个的响应到达，它将在websocket上发出。一个要求是不要杀死API，所以只要主进程正在运行，就假设每5秒点击一次。
我正在苦苦挣扎的重要部分是如何接近它。我在这一点上所做的是，主进程正在为不同的API产生单独的线程，并且该线程正在命中API，向websocket time.sleep(5)发出响应并重复。主进程负责启动新的“工作进程”，并杀死不再需要的“工作进程”，也负责重启本应正常工作但不是由于异常导致的进程。我不知道多线程是否是这里的方式-假设我的目标
浏览 0提问于2019-05-06得票数 0
1回答
松开按钮控制在猕猴桃中的结合
、、、、
我有一个小录音机应用在基维，应该控制屏幕捕捉活动。记录器应用程序应该显示一个状态线和一个记录/暂停按钮，这取决于记录器的状态。最初的顺序是:等待(即等待某些动作--按rec按钮)> Set Application (即enduser应该通过鼠标单击将其他应用程序窗口带到前台)>记录(从鼠标单击获取屏幕图像)>暂停或停止。为了触发捕获活动，我使用pyHook读取鼠标事件。但是，一旦调用了pyHook.HookManager()，我就失去了对kivy记录器应用程序的访问权限，无法控制记录过程:没有捕获按钮单击，也没有更新状态行和事件ID。我在这里错过了什么？
附加了Python代
浏览 2提问于2016-02-20得票数 0
回答已采纳
2回答
我想使用node.js 处理计划好的作业。基本上，我有两个处理器，处理两种类型的作业。有一个配置器，它配置将使用cron添加到牛队列中的作业。
调度程序将在一个微服务中，每个处理器将是一个单独的微服务。所以我将有3个微型服务。
我的问题是，我是否对公牛使用了正确的模式？
index.js
const Queue = require('bull');
const fetchQueue = new Queue('MyScheduler');
fetchQueue.add("fetcher", {name: "earthQuakeAlert&
浏览 13提问于2019-09-22得票数 3
回答已采纳
1回答
因此，我一直困惑于谷歌对新应用的“审查”过程。
他们应该如何在没有用户名和密码等认证细节的情况下真正地审查我的应用程序呢？我想知道这一点，因为我95%的应用程序被锁定在API身份验证之后。
我刚刚在我的应用程序上做了初步的发布，它正在等待发布，我注意到他们在我的用户名字段中乱发似乎毫无意义的数据。
注意:它只是垃圾邮件的用户名字段，因为它是一个2步认证，在其中您首先输入您的用户名，然后，如果它存在，您输入您的密码，如果它不存在，它提供注册。
快速编辑，一个问题被问到：“你确定它是谷歌而不是攻击吗? AFAIK，谷歌所做的只是对文件进行静态分析。”
对于这个问题，我的回答是：“是的，我在大约4小
浏览 3提问于2020-02-28得票数 0
回答已采纳
3回答
我希望编写一个守护进程：
从队列中读取消息(sqs、兔子-mq，任何.)包含指向zip文件的路径。
更新数据库中的一个记录，上面写着“这个作业正在处理”
读取上述存档的内容，并将一行插入到数据库中，为找到的每个文件从文件元数据中筛选出信息
将每个文件复制到s3
删除zip文件。
将这项工作标记为“完成”
在队列中读取下一条消息，重复
这应该以服务的形式运行，并且在某人通过web前端上传文件时由排队的消息发起。上传者不需要立即看到结果，但上传在后台处理相当方便。
我非常熟悉python，所以首先想到的就是编写一个简单的服务器，它可以处理每个请求并执行上面提到的
浏览 9提问于2009-04-16得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
