Laravel - 按顺序运行作业

2024-02-01

我正在学习 Laravel,正在开发一个运行 Horizo​​n 来了解工作的项目。我被困在一个地方,我需要一次又一次地运行相同的工作几次。

这是我目前正在做的事情

<?php

namespace App\Http\Controllers;

use App\Http\Controllers\Controller;
use App\Models\Subscriptions;
class MailController extends Controller
{


    public function sendEmail() {
        Subscriptions::all()
        ->each(function($subscription) {
            SendMailJob::dispatch($subscription);
        });
    }
}

这工作得很好,除了它在多个工作人员之间运行作业并且不按保证的顺序运行。有没有办法让作业一个接一个地运行?


正如您在问题中提到的,您正在寻找的是工作链。

来自 Laravel 文档 https://laravel.com/docs/5.7/queues#job-chaining

作业链允许您指定应按顺序运行的排队作业列表。如果序列中的一项作业失败,则其余作业将不会运行。要执行排队作业链,您可以在任何可分派作业上使用 withChain 方法:

ProcessPodcast::withChain([
    new OptimizePodcast,
    new ReleasePodcast
])->dispatch();

所以在你上面的例子中

$mailJobs = Subscriptions::all()
    ->map(function($subscription) {
        return new SendMailJob($subscription);
    });

Job::withChain($mailJobs)->dispatch()

应该给出预期的结果!

Update

如果您不想使用初始作业来链接(如上面的文档示例所示),您应该能够创建一个空的Job具有的类use Dispatchable;。那么你可以使用我上面的例子

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

Laravel - 按顺序运行作业 的相关文章

随机推荐

  • XSLT 聚合 XML 标记值并存储新标记

    我是 xslt 的新手 并尝试使用 XSLT 处理以下 XML
  • 奥尔良任务的交错

    有一个问题here https stackoverflow com questions 54456369 orleans single threaded nature not respected by continuewith其中 Orle
  • 如何使用 knit::spin 注释掉行

    使用时spin包装内knitr 如何简单地注释掉一些东西 使它们看不见旋转 roxygen风格线 被视为出现在报告中的行 通常的 R 注释 被视为R注释并出现在代码块中 仅是文本且开头没有特殊字符的行会导致错误 以 开头的行LaTeX评论
  • PHP 类自动加载

    我有一个 简单框架 其主要实例是 app 现在 实现自动加载器的最佳方法是什么 不使用 Composer 我需要的是有一个处理所有自动加载的类 支持各种名称空间 我有一些方法 困境 起初我认为我应该创建一个处理所有事情的 静态 类 但后来我
  • Boost random::discrete_distribution 构建后如何更改权重?

    好的 可以在 boost random discrete distribution 中给出权重 概率 e g 双倍概率 0 5 0 1 0 1 0 1 0 1 0 1 boost random discrete distributiondi
  • 使用 PowerShell 重命名文件以增加文件编号?

    我有一堆名为 attachment 023940 attachment 024039 attachment 024041 attachment 024103 etc 我需要通过将文件号增加给定的数字来重命名文件 以便它们与数据库中的正确 I
  • gperftools CPU profiler 究竟是如何启动的?

    gperftools 文档 http google perftools googlecode com svn trunk doc cpuprofile html说libprofiler应该链接到目标程序 gcc myprogram c lp
  • 无法从具有多个返回的 Select 中的使用情况推断出 C# 类型参数

    我不认为我做了任何太深奥的事情 但我没有看到任何其他与此相关的问题 以下代码 我已将其简化为要点 在 C 4 中生成编译器错误 但是 类型参数是什么应该是显而易见的 有一个最大公分母 类 A 也明确定义在方法 Frob 的返回类型 难道编译
  • NodeJS base64 图像编码/解码不太工作

    我一直在尝试将发布到nodeJS 和express框架 的图像保存到数据库 但遇到了一些麻烦 忽略所有的 Web 处理 我认为我已经将问题范围缩小到了 Node js 中进行 Base64 编码的方式 我相信下面过于简化的示例应该可以工作
  • 如何将 tibble 导出为 .csv

    我使用 rfm 包进行了 rfm 分析 结果在 tibble 中 我似乎不知道如何将其导出到 csv 我尝试了下面的参数 但它导出了一个空白文件 gt dim bmdata4RFM 1 1182580 3 gt str bmdata4RFM
  • C 中的 #line 关键字

    我试图理解一些代码 但遇到了一个我以前从未见过的关键字 我尝试用谷歌搜索它 但也没有找到任何有关它的信息 char valtext line 1 Values l define INITIAL 0 line 2 Values l int r
  • 如何使用注释在 Spring MVC 中创建默认方法?

    我找不到解决办法 这让我发疯 我映射了 Controller 它使用 RequestMapping 响应多种方法 当没有指定更具体的情况时 我想将其中一种方法标记为默认方法 例如 Controller RequestMapping user
  • 使用 Click 库的 Python 3.6 中没有模块错误

    我正在尝试使用该包在 python 中构建 CLIclick 我使用的Python版本是3 6 这是我的应用程序的主要部分 import os import click cmd folder os path join os path dir
  • php if() 中的多个 OR 似乎没有正确响应。测试数组值和所有。我究竟做错了什么?

    我正在运行一个非常简单的 if 语句 在我添加两个额外的 之前它工作得很好 或 运算符 这是我的代码 if planDetails Company name company1 planDetails PlanDetail name pd n
  • Spring JPA自动创建表失败

    我对 Spring JPA Hibernate MySQL 有疑问 我有一个实体 Nom java 和存储库 公共接口 NomRepository 扩展 JpaRepository 它们的创建和注入都很好 问题是 当我尝试通过存储库的保存方
  • 如何以经过身份验证的方式运行应用程序

    我创建了一个小型应用程序 它尝试根据用户的用户名和密码对用户进行身份验证 当在 Active Directory 所在的同一域上运行时 此应用程序可以正常工作 我现在必须扩展该应用程序 使其也可以在安全和权限方面 封闭 的域上运行 换句话说
  • 为什么 PostgreSQL 枚举类型数组允许空值?

    我正在使用 PostgreSQL 数据库 并使用枚举类型的数组作为其中一列 CREATE TYPE my type enum AS ENUM value1 value2 value3 ALTER TABLE my table ADD COL
  • JsonMappingException:无法构造 CommonsMultipartFile 的实例

    我正在使用 Spring MVC 3 0 在我的应用程序中 我发送一些带有多个附件的信息 并且每个文件都有标题 Id 等 因此 我制作了一个 DTO 如下所示 public class MyDTO Long id Integer age M
  • 如何在Bootstrap中选择960px宽而不是1200px的容器

    如何选择容器960pxBootstrap 中宽而不是 1200px Bootstrap 在宽度超过 1200 像素的屏幕上将容器宽度设置为 1170 像素 对于 992px 到 1200px 的屏幕 容器宽度设置为 970px 您可以阅读有
  • Laravel - 按顺序运行作业

    我正在学习 Laravel 正在开发一个运行 Horizo n 来了解工作的项目 我被困在一个地方 我需要一次又一次地运行相同的工作几次 这是我目前正在做的事情