{"id":14278,"date":"2017-09-19T17:51:35","date_gmt":"2017-09-19T14:51:35","guid":{"rendered":"https:\/\/belvg.com\/blog\/?p=14278"},"modified":"2019-03-19T10:32:49","modified_gmt":"2019-03-19T08:32:49","slug":"module-to-use-amazon-sqs-queues","status":"publish","type":"post","link":"https:\/\/belvg.com\/blog\/module-to-use-amazon-sqs-queues.html","title":{"rendered":"Magento 2 Module To Use Amazon SQS"},"content":{"rendered":"

Magento 2 is distinguished by the number of features Magento 1 feels lack. One of the examples is Queues which allow executing time and resource-consuming tasks such as product import, stocks management, API interfaces, indexation<\/span> asynchronously. Magento 2 box version provides interfaces for accessing AMQP and MySQL queues.  As for MySQL, the queues are based on the cron job tasks. This solution performs great for middle-size websites. But there’s an issue concerning high-load projects, as cron job can not manage all scheduled tasks during one iteration. In such a way, the queue can become a potential source of serious bugs. <\/span><\/p>\n

Our investigations showed that RabbitMQ can be considered as the way out. RabbitMQ service can be connected to Magento 2 by creating a separate module with the queue.xml file, that defines the Queue connection attribute type=”amqp” in it. This workflow gives us access to all Queue functions and allows us to expand default functionality with additional features. <\/span><\/p>\n

The only real problem you can face while using RabbitMQ is that not every hosting company is eager to install RabbitMQ service by your request. You can setup everything yourself, but it’s not convenient and requires much effort and administrative knowledge.  <\/span><\/p>\n

Let’s suppose Amazon doesn’t provide queues service on RabbitMQ, but it has its own queues service – SQS. The service is simpler than RabbitMQ and doesn’t have additional options. But in most cases, all these extra options are not necessary. As a rule, you need the queue to send messages. SQS has obvious benefit if compared with RabbitMQ. In Amazon ecosystem SQS is available everywhere and doesn’t need to be installed separately. After weighing all the pros and cons, we decided to create a separate module which allows using Amazon SQS service with Magento 2 Queues with ease. You can download the module via <\/span>packagist<\/a>.<\/span><\/p>\n

Now let’s consider how to install the module. In order to connect the module, in the file  app\/etc\/env.php in the section “queues”, you need to enter credentials in the following format:<\/span><\/p>\n

'queue' =>\r\narray (\r\n'sqs' =>\r\narray (\r\n  'region' => '',\r\n  'version' => '',\r\n  'access_key' => '',\r\n  'secret_key' => '',\r\n)\r\n<\/pre>\n
Then in the file <module_path>\/etc\/queue.xml<\/strong>  you need to update connection type into SQS. <\/span><\/p>\n
<config xmlns:xsi=\"http:\/\/www.w3.org\/2001\/XMLSchema-instance\" xsi:noNamespaceSchemaLocation=\"urn:magento:framework-message-queue:etc\/queue.xsd\">\r\n  <broker topic=\"name.topic\" type=\"sqs\" exchange=\"magento\">\r\n      <queue consumer=\"consumerName\" name=\"queue.name\"\/>\r\n  <\/broker>\r\n<\/config><\/pre>\n
Now it’s configured. The rest of it is described in the documents. The only thing you should pay attention to is to specify topology module dependency (belvg\/module-sqs) in the setup file when installing the module. Here is the example:<\/span><\/p>\n
\/**\r\n* UpgradeSchema constructor.\r\n* @param Topology $topology\r\n*\/\r\npublic function __construct(Belvg\\Sqs\\Model\\Topology  $topology)\r\n{\r\n  \/** @var TYPE_NAME $topology *\/\r\n  $this->topology = $topology;\r\n}\r\n…\r\n$this->topology->install();\r\n...\r\n<\/pre>\n
P.S. The module was tested on Magento 2.1.3-2.1.7 EE. Any bugs can be submitted to the repository <\/span>https:\/\/github.com\/Galillei\/magento-sqs<\/span><\/a>.<\/span><\/p>\n","protected":false},"excerpt":{"rendered":"Magento 2 is distinguished by the number of features Magento 1 feels lack. One of …","protected":false},"author":47,"featured_media":14279,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"image","meta":{"_acf_changed":false,"footnotes":""},"categories":[14,389],"tags":[],"class_list":["post-14278","post","type-post","status-publish","format-image","has-post-thumbnail","hentry","category-magento","category-magento2-development","post_format-post-format-image"],"acf":[],"aioseo_notices":[],"aioseo_head":"\n\t\t\n\t\n\t\n\t\n\t\n\t\t\n\t\t