Lumen 5.1 SQS 队列配置

Question

我使用 Lumen 创建了一个新项目，用于发送电子邮件和其他一些小任务。但是，对于一些需要发送的邮件，我想使用亚马逊的队列。

在 Lumen 的文档中，他们唯一提到的是： .env 文件中的 QUEUE_DRIVER 选项决定了您的应用程序将使用的队列 "driver"。

我已按照建议将其设置为 SQS，但我对实际的亚马逊凭据感到有些困惑。我应该如何定义这些？我唯一看到的 "relevant" 是来自 Amazon 的文档 here and here。我还安装了 "aws/aws-sdk-php": "~3.0" 包。

但是这些资源是指直接使用 SQS 的 API。我希望能够调用流明中描述的队列，所以像 Queue::push() 或 $this->dispatch().

这是我的相关代码。

这在我的 .env 文件中

QUEUE_DRIVER=sqs
AWS_KEY=key
AWS_SECRET=secretstuff
AWS_QUEUE=https://sqs.eu-west-1.amazonaws.com/
AWS_REGION=eu-west-1

这是我的控制器

<?php namespace App\Http\Controllers;

use App\Jobs\GuestEmailJob;
use Laravel\Lumen\Routing\Controller as BaseController;
use Log, Queue;
use Aws\Sqs\SqsClient;

class NotificationEmailController extends BaseController
{
    public function pushToQueue($id)
    {
        Queue::push(new GuestEmailJob($id));
        //$this->dispatch(new GuestEmailJob($id));
    }
}

最后这是我的工作

<?php namespace App\Jobs;

use Illuminate\Bus\Queueable;
use Illuminate\Queue\SerializesModels;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Bus\SelfHandling;
use Illuminate\Contracts\Queue\ShouldQueue;
use Log;

abstract class GuestEmailJob implements SelfHandling, ShouldQueue
{
    use InteractsWithQueue, Queueable, SerializesModels;

    public function handle($id)
    {
        Log::info('within handle');
        $user = User::find($id);
    }
}

我已经用 Queue::push 和 $this->dispatch() 试过了。当请求到达控制器时，一切正常，直到推送到队列然后什么都没有发生（也没有例外）。有人知道我在做什么 wrong/missing?

Answer 1

仔细查看源代码后，显然您应该在 config 目录下有 queue.php 配置文件。所以我只是粘贴了 laravel 5 中的默认配置文件并对其进行了自定义，现在它可以正常工作了。毕竟这是一个非常愚蠢的问题，但文档本身并不清楚。这是默认队列配置，以防万一有人遇到这个问题。

<?php

return [

    'default' => env('QUEUE_DRIVER', 'sync'),

    'connections' => [

        'sync' => [
            'driver' => 'sync',
        ],

        'database' => [
            'driver' => 'database',
            'table' => 'jobs',
            'queue' => 'default',
            'expire' => 60,
        ],

        'beanstalkd' => [
            'driver' => 'beanstalkd',
            'host'   => 'localhost',
            'queue'  => 'default',
            'ttr'    => 60,
        ],

        'sqs' => [
            'driver' => 'sqs',
            'key'    => 'your-public-key',
            'secret' => 'your-secret-key',
            'queue'  => 'your-queue-url',
            'region' => 'us-east-1',
        ],

        'iron' => [
            'driver'  => 'iron',
            'host'    => 'mq-aws-us-east-1.iron.io',
            'token'   => 'your-token',
            'project' => 'your-project-id',
            'queue'   => 'your-queue-name',
            'encrypt' => true,
        ],

        'redis' => [
            'driver' => 'redis',
            'connection' => 'default',
            'queue'  => 'default',
            'expire' => 60,
        ],

    ],

    'failed' => [
        'database' => 'mysql', 'table' => 'failed_jobs',
    ],

];

Lumen 5.1 SQS 队列配置

Lumen 5.1 SQS queue configuration

amazon-sqs

laravel-5

lumen