Laravel和AWS SQS，如何读取作业负载/检索队列

Question

在过去的3天里，我一直在为如何在Laravel中读取排队作业负载而苦苦挣扎。

我迄今为止所取得的成就。分派一个作业，并查看它在AWS SQS队列中是否可用。在那之后，我为AWS执行了监听器和worker来处理排队的作业，我发现它也运行得很好。

现在，我一直在思考如何从AWS SQS读取QUEUED作业有效负载/messagebody/attributes。

这是我的代码示例，如果可能的话，请帮助我

<?php
namespace AppJobs;
use AppCookieXrayConsentLog;
use AppCookieXrayScript;
use CarbonCarbon;
use IlluminateBusQueueable;
use IlluminateQueueSerializesModels;
use IlluminateQueueInteractsWithQueue;
use IlluminateContractsQueueShouldQueue;
use IlluminateFoundationBusDispatchable;
use IlluminateSupportFacadesDB;
use IlluminateSupportFacadesLog;
use IlluminateSupportFacadesQueue;
use IlluminateSupportFacadesStorage;
class QueueCookieConsent implements ShouldQueue
{
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
protected $job;
// The maximum attempts of this job

public $tries = 5;
/**
* Create a new job instance.
*
* @return void
*/
public function __construct(array $data)
{
$this->job = $data;
$this->onConnection('sqs');
$this->onQueue('dev_consent');
}
/**
* Execute the job.
*
* @return void
*/
public function handle()
{
// Tried by these ways
Log::info('job => ' .' This --- '. json_encode(Queue::pop()->payload()));

Log::info('job => ' .' This --- '. json_encode($this->job));
}
}

如果我如上所述从日志信息中删除这个json_encode((，则会打印日志。

Answer 1

在您的情况下，您想要访问$this->job->payload()，但您正在用此行覆盖构造函数中的作业变量。

$this->job = $data;

相反，请将其重命名为其他名称。

$this->data = $data;

现在你可以这样访问有效载荷了。

$this->job->payload()