如何使用laravel向sqs发送json消息？

Question

我是 Laravel 的初学者。在我的任务中，我需要做以下几点：-

1. 在控制器中，将 csv 文件的内容存储在数组中。 - - 完全的

2. 在同一个控制器中，使用 laravel 将 json 格式的步骤 1. 数组发送到 sqs（亚马逊）。 - - 待办的

3. 对于第 2 步），我已经设置了 config/queue.php

'sqs' => [
            'driver' => 'sqs',
            'key' => env('AWS_ACCESS_KEY_ID'),
            'secret' => env('AWS_SECRET_ACCESS_KEY'),
            'prefix' => env('SQS_PREFIX', 'https://sqs.ap-northeast-1.amazonaws.com/xxxxxxx'),
            'queue' => env('SQS_QUEUE', 'xxxxx'),
            'region' => env('AWS_DEFAULT_REGION', 'ap-northeast-1'),
        ],

还更改了 .env 文件

AWS_ACCESS_KEY_ID=xxxx
AWS_SECRET_ACCESS_KEY=xxxxxxx
SQS_QUEUE=data_queue_name_aws

2. 创建了一个工作 php artisan make:job SendMessageSQS

3. 称呼 SendMessageSQS::dispatch();

4. SQS收到消息

{"displayName":"App\\Jobs\\SendMessageSQS","job":"Illuminate\\Queue\\CallQueuedHandler@call","maxTries":null,"delay":null,"timeout":null,"timeoutAt":null,
  "data":{"commandName":"App\\Jobs\\SendMessageSQS","command":"O:21:\"App\\Jobs\\SendMessageSQS\":3:{s:7:\"\u0000*\u0000item\";s:7:\"testing\";s:10:\"connection\";
  s:7:\"sqs\";s:6:\"\u0000*\u0000job\";N;}"}}

5. 如何发送

$userIDs = [1,2,3]; // array values from csv file column `user-is`
$sendMessageSqs["file-name"] = "test-sqs-1";
$sendMessageSqs["user-id"] = $userIDs;

6. 实际结果：SQS 应以以下格式存储

{"file-name":"test-sqs-1","user-id":"1,2,3"}

Answer 1

您可以发送原始消息：

Queue::connection('sqs')->pushRaw('payload_body', 'queue_name');

一般情况下，它调用SqsQueue->pushRaw方法，它调用SqsClient从aws-sdk-php实际上发送消息