maqe/laravel-sqs-fifo

Laravel 包，用于支持 SQS FIFO 队列

维护者

详细信息

github.com/maqe/laravel-sqs-fifo

源代码

问题

安装次数: 129,477

依赖项: 0

建议者: 0

安全性: 0

星标: 14

关注者: 4

分支: 12

开放性问题: 5

v0.1.0 2016-12-07 12:55 UTC

Requires

Requires (Dev)

MIT c3ea2e8b6746c46c81154d6e8b9ddac9261ac797

queuelaraveljobsqsfifo

This package is auto-updated.

Last update: 2024-09-07 09:38:56 UTC

README

为 Laravel 添加对 SQS FIFO 队列的支持。

设置

将包依赖添加到您的项目中

composer require maqe/laravel-sqs-fifo

在 Laravel 5.5 之前，将包的服务提供者添加到项目的 config/app.php

'providers' => [
    Maqe\LaravelSqsFifo\LaravelSqsFifoServiceProvider::class,
],

此包可通过 Laravel 5.5 自动发现。

配置

然后您可以通过将其添加到您的 config/queue.php 文件来创建一个 SQS FIFO 队列连接

'connections' => [

    ...

    'my_sqs_fifo' => [
        'driver' => 'sqsfifo',
        'key'    => env('AWS_ACCESS_KEY_ID'),
        'secret' => env('AWS_SECRET_ACCESS_KEY'),
        'queue'  => env('AWS_SQS_URL'),
        'region' => env('AWS_SQS_REGION'),
    ],
],

然后您可以通过在 config/queue.php 中设置来使用此 FIFO 队列为默认

    'default' => 'my_sqs_fifo',

或特定地调用/监听 FIFO 队列

Queue::connection('my_sqs_fifo')->pushOn('my_queue_name', new MyQueueJob); // Laravel 5.1

(new MyQueueJob)->onConnection('my_sqs_fifo'); // Laravel 5.2+
php artisan queue:listen connection
php artisan queue:work connection