Send Product Data to Amazon SQS When a New Product is Created in Shopify

This use case describes how to send product data to an Amazon SQS queue whenever a product is created in a Shopify application using Oracle Integration. The product data can then be consumed from the Amazon SQS queue by downstream systems.

The following adapters and their operations are used in this use case:
  • Shopify Adapter: (configured as a trigger connection) Captures the Product Create event in Shopify.
  • Amazon Simple Queue Service (SQS) Adapter: (configured as an invoke connection) Performs the following operations:
    • Send operation: Sends product data to an AWS SQS queue.
    • Receive operation: Reads messages from an AWS SQS queue.

This implementation pattern provides an overview of the steps:

  1. Create a Shopify Adapter trigger connection and an Amazon Simple Queue Service (SQS) Adapter invoke connection.
  2. Create an application integration.
  3. Drag the Shopify Adapter into the integration canvas as a trigger connection.
  4. Configure the Shopify Adapter endpoint as follows:
    1. On the Basic Info page, provide an endpoint name.
    2. On the Events page, select Products as the module and Product Create as the event.
    3. On the Summary page, review and confirm your selections.
  5. Drag the Amazon Simple Queue Service (SQS) Adapter into the integration canvas as an invoke connection.
  6. Configure the Amazon Simple Queue Service (SQS) Adapter endpoint as follows:
    1. On the Basic Info page, provide an endpoint name.
    2. Select Message as the resource and Send Message as the action.
    3. On the Send Message Actions page, specify the message structure.
    4. On the Summary Page, review and confirm your selections.
  7. Use the mapper to map the product data from the Shopify trigger to the SQS message structure.
  8. Drag another Amazon Simple Queue Service (SQS) Adapter into the integration canvas as a second invoke connection.
  9. Configure the Amazon Simple Queue Service (SQS) Adapter endpoint as follows:
    1. On the Basic Info page, provide a meaningful name for the endpoint.
    2. Select Message as the resource and Receive Messages as the action.
    3. On the Receive Messages Actions page, specify the message structure.
    4. On the Summary Page, review and confirm your selections.
  10. When complete, activate the integration.

    The completed integration looks as follows:


    The integration shows a trigger connection, map action, invoke connection, map action, and invoke connection.

    Once activated, this integration is automatically triggered when a new product is created in Shopify. The product details are sent to the AWS SQS queue and then read from the queue using the Amazon Simple Queue Service (SQS) Adapter.