subscriptions

Query message Subscriptions (change-event delivery to SQS / Pub-Sub / EventBridge / Azure) with a `where` predicate and paging.

Use it in a workflow

Add a step and choose the Commercetools connector.
Pick the subscriptions action (under Subscriptions).
Fill in the fields below, then reference the result from later steps as {{subscriptions.response.data}}.

Query

This is the query the action sends by default. Edit it in the step's Query field to change which fields come back.

graphql

query Subscriptions($where: String, $sort: [String!], $limit: Int, $offset: Int) {
  subscriptions(where: $where, sort: $sort, limit: $limit, offset: $offset) {
    offset
    count
    total
    exists
    results {
      key
      destination {
        type
      }
      messages {
        resourceTypeId
        types
      }
      changes {
        resourceTypeId
      }
      events {
        resourceTypeId
        types
      }
      format {
        type
      }
      status
      id
      version
      createdAt
      lastModifiedAt
      createdBy {
        isPlatformClient
        clientId
        externalUserId
        anonymousId
        customerRef
        userRef
        associateRef
        attributedTo
      }
      lastModifiedBy {
        isPlatformClient
        clientId
        externalUserId
        anonymousId
        customerRef
        userRef
        associateRef
        attributedTo
      }
    }
  }
}

Variables

Pass these as a JSON object in the step's Variables field.

wherestring

sortarray<string>

limitnumber

offsetnumber

json

{
  "where": "string",
  "sort": [
    "string"
  ],
  "limit": 0,
  "offset": 0
}

Response

Read the result with {{subscriptions.response.data.data.subscriptions}}. If the API returns errors, the step fails and they are at {{subscriptions.response.data.errors}}.

offsetnumber

countnumber

totalstring

existsboolean

resultsarray<object>

keyobject

destinationobject

messagesobject

changesobject

eventsobject

formatobject

statusobject

idobject

versionobject

createdAtobject

lastModifiedAtobject

createdByobject

lastModifiedByobject

Need more? See the Commercetools guide for connection setup and behaviour shared by every action.

Was this page helpful?