beanstalkd

    5热度

    1回答

    这涉及到laravel 5.3,beanstalk,ttr和timeout以及Queue和QueueWorkers。 TTR:https://github.com/kr/beanstalkd/wiki/faq 如果我理解正确,QueueWorker正在选择QueueWorker时,队列中的作业将获得保留的状态。当ttr用完时,这个工作状态将变回准备状态。但是QueueWorker会发生什么? 比方

    0热度

    1回答

    有3台机器和一个发布者,两个消费者。 我正在使用golang将订单发布到某台机器。 而这台机器是用python作为消费者。 我想知道如何获得订单在发布者中完成或失败的结果。 如果订单不属于机器,我该怎么办? 发布还是埋葬? 蟒蛇: 消费者: import beanstalkc def get_beanstalk_data(conf): beanstalk = beanstalkc.C

    0热度

    1回答

    我在那里有 电流工作紧急的问题:344 电流工作就绪:344 我在10分钟后检查了它,它仍然在344. 这是否意味着我的Beanstalk已备份?

    0热度

    1回答

    我试图完成的是构建最简单的系统来处理通过消息队列进行图像上传。 现在我们正在处理临时文件,我们为每个需要通过Aws S3发送的图像创建一个,并根据我们的需要对其进行优化/定制。一旦完成所有这些,我们就把它推到S3。 现在,这个工作正常,但我想通过使用图像的base64编码来删除文件系统开销,使得该进程完全与应用程序运行的系统分离。 由于我们打算使用Amazon SQS(我们目前在生产中使用Bean

    1热度

    1回答

    我们有一堆文件要处理后上传到远程blob存储。 目前,前端(PHP)创建了一个这样的文件的redis列表,并给它一个唯一的ID,称为JobID。然后它将这个唯一的ID传递给一个豆杆管,这个管通过一个Go进程接收。它使用名为Go workers的库来按照net/http所做的方式处理每个作业ID。它接收作业ID,检索redis列表并开始处理文件。 但是,目前一次只能处理一个文件。由于这里的操作是I/

    0热度

    1回答

    我有一个3 beanstalkd队列进程运行在相同的ip但不同的端口上。我有一个单独的服务器运行主管并行产生php工作(每个beanstalkd端口20)来处理队列。我的问题是,似乎两个进程可以在同一台服务器上同时保留相同的作业ID。 下面是我的一些日志输出样本: 2017-02-23 09:59:56 --> START JOB (port: 11301 | u: 0.45138600 1487

    0热度

    1回答

    我有一个远程服务器(Ubuntu 16.04),安装了beanstalkd。我已经成功地用下面的命令启动的消息队列: beanstalkd -l 123.123.123.123 -p 11300 & 在我的本地,我已经安装了beanstalkd,我试图用命令连接到远程队列: beanstalkd -l 123.123.123.123 -p 11300 & 但我m出现错误: beanstal

    1热度

    1回答

    嗨我所有的麻烦对我的pheanstalk抱歉,这是我第一次使用它。我的项目涉及到一个保存5000个条目,当我工作时,由于交通请求获取502。所以我的解决方案是在这个过程中使用pheanstalk,这里是我的代码,下面是可以的。我已经在服务器上安装了beanstalk。 require("vendor/autoload.php"); use Pheanstalk\Pheanstalk; $phe

    0热度

    1回答

    我想用现有的代码设置Django服务器。但我似乎停留在这一点的同时尝试使用python manage.py runserver 这个追溯启动服务器: (camdyvirtualenv) Mac-mini-3:big-picture-api Sqooge_Ahmed$ python manage.py runserver Traceback (most recent call last):

    0热度

    1回答

    我想在保存django模型时创建beanstalkd作业。为此,我正在听模型的post_save信号和相关的处理程序创建一个beanstalkd工作就像下面的例子(myapp/signals.py): @receiver(post_save, sender=MyModel) def create_job(sender, **kwargs): beanstalk = beanstalkc