如何使用Laravel Queue在S3上拦截新文件？

我找到了一种获取所需行为的方法，但是我不确定这是否是最佳方法，因此我将其发布在这里，也许可以给我反馈。当我们谈论Laravel Queues时，很多配置来自app.php，特别是来自本Provider节。我设法添加了我需要覆盖原始QueueServiceProvider类的行为并替换了它：// Here is the original Provider Class//Illuminate\Queue\QueueServiceProvider::class,// Here is the overridden Provider\App\Providers\QueueServiceProvider::class, 新QueueServiceProvider类如下：<?phpnamespace App\Providers;use App\Jobs\SqsNotifications\SqsConnector;class QueueServiceProvider extends \Illuminate\Queue\QueueServiceProvider{    /**     * Register the Amazon SQS queue connector.     *     * @param  \Illuminate\Queue\QueueManager  $manager     * @return void     */    protected function registerSqsNotifConnector($manager)    {        $manager->addConnector('sqsNotif', function () {            return new SqsConnector();        });    }    public function registerConnectors($manager){        parent::registerConnectors($manager);        // Add the custom SQS notification connector        $this->registerSqsNotifConnector($manager);    }}请注意sqsNotif，需要将新的连接器添加到queue.php 'sqsNotif' => [        'driver' => 'sqsNotif',        'key' => env('AWS_ACCESS_KEY_ID'),        'secret' => env('AWS_SECRET_ACCESS_KEY'),        'prefix' => env('SQS_PREFIX', 'https://sqs.eu-central-1.amazonaws.com/your-account'),        'queue' => env('SQS_QUEUE', 'your-queue-name'),        'region' => env('AWS_DEFAULT_REGION', 'eu-central-1'),],在新版本中，QueueServiceProvider我们仅注册了一个额外的连接器，其代码为：<?phpnamespace App\Jobs\SqsNotifications;use Aws\Sqs\SqsClient;use Illuminate\Support\Arr;class SqsConnector extends \Illuminate\Queue\Connectors\SqsConnector{    /**     * Establish a queue connection.     *     * @param  array  $config     * @return \Illuminate\Contracts\Queue\Queue     */    public function connect(array $config)    {         $config = $this->getDefaultConfiguration($config);        if ($config['key'] && $config['secret']) {            $config['credentials'] = Arr::only($config, ['key', 'secret', 'token']);        }        return new SqsQueue(            new SqsClient($config), $config['queue'], $config['prefix'] ?? ''        );    }}SqsQueue也以这种方式重新定义：<?phpnamespace App\Jobs\SqsNotifications;class SqsQueue extends \Illuminate\Queue\SqsQueue{   /**    * Pop the next job off of the queue.    *    * @param  string  $queue    * @return \Illuminate\Contracts\Queue\Job|null    */    public function pop($queue = null)    {        $response = $this->sqs->receiveMessage([            'QueueUrl' => $queue = $this->getQueue($queue),            'AttributeNames' => ['ApproximateReceiveCount'],        ]);        if (! is_null($response['Messages']) && count($response['Messages']) > 0) {            return new SqsJob(                $this->container, $this->sqs, $response['Messages'][0],                $this->connectionName, $queue            );        }    }}最后缺少的部分是SqsJob，其定义如下：<?phpnamespace App\Jobs\SqsNotifications;use Illuminate\Queue\Jobs\JobName;/** * Class SqsJob * @package App\Jobs\SqsNotifications * * Alternate SQS job that is used in case of S3 notifications */class SqsJob extends \Illuminate\Queue\Jobs\SqsJob{    /**     * Get the name of the queued job class.     *     * @return string     */    public function getName()    {        $bucketName = '';        // Define the name of the Process based on the bucket name        switch($this->payload()['Records'][0]['s3']['bucket']['name']){            case 'mybucket':                $bucketName = 'NewMyBucketFileJob';                break;        }        return $bucketName;    }   /**    * Fire the job.    *    * @return void    */    public function fire()    {        // Mimic the original behavior with a different payload        $payload = $this->payload();        [$class, $method] = JobName::parse('\App\Jobs\\' . $this->getName() . '@handle');        ($this->instance = $this->resolve($class))->{$method}($payload);        // The Job wasn't automatically deleted, so we need to delete it manually once the process went fine        $this->delete();    }}在这一点上，我只需要在a中定义处理Job，例如下面的代码NewMyBucketFileJob：<?phpnamespace App\Jobs;use Illuminate\Bus\Queueable;use Illuminate\Queue\SerializesModels;use Illuminate\Queue\InteractsWithQueue;use Illuminate\Contracts\Queue\ShouldQueue;use Illuminate\Foundation\Bus\Dispatchable;class ProcessDataGateNewFile implements ShouldQueue{    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;    /**     * Create a new job instance.     *     * @return void     */    public function __construct()    {    }    /**     * Execute the job.     *     * @return void     */    public function handle($data)    {                // Print the whole data structure        print_r($data);        // Or just the name of the uploaded file        print_r($data['Records'][0]['s3']['object']['key']);    }}这个过程是可行的，所以这是一个解决方案，但是涉及许多类扩展，并且在将来的版本中内部队列实现将被更改时，它非常脆弱。老实说，我想知道是否有更简单或更强大的方法

如何使用Laravel Queue在S3上拦截新文件？

1回答