Datakit: Combine multiple API responses - Plugin

Combine multiple API responsesv3.11+

Make requests to multiple APIs and combine their responses into one response.

This example contains the following nodes:

The node AUTHOR makes a GET request to the API at https://httpbin.konghq.com/json.
The node UUID makes a GET request to the API at https://httpbin.konghq.com/uuid.
The node JOIN combines the JSON response bodies of AUTHOR and UUID into a single JSON object.
The node EXIT sends a response to the client with the combined API response data. This terminates the request instead of proxying it upstream.

Set up the plugin

Add this section to your kong.yaml configuration file:

kong.yaml

Copied!

_format_version: "3.0"
plugins:
  - name: datakit
    config:
      nodes:
      - name: AUTHOR
        type: call
        url: https://httpbin.konghq.com/json
      - name: UUID
        type: call
        url: https://httpbin.konghq.com/uuid
      - name: JOIN
        type: jq
        inputs:
          input1: AUTHOR.body
          input2: UUID.body
        jq: |
          {
            author: .input1.slideshow.author,
            uuid: .input2.uuid,
          }
      - name: EXIT
        type: exit
        inputs:
          body: JOIN
        status: 200

Make the following request:

curl -i -X POST http://localhost:8001/plugins/ \
    --header "Accept: application/json" \
    --header "Content-Type: application/json" \
    --data '
    {
      "name": "datakit",
      "config": {
        "nodes": [
          {
            "name": "AUTHOR",
            "type": "call",
            "url": "https://httpbin.konghq.com/json"
          },
          {
            "name": "UUID",
            "type": "call",
            "url": "https://httpbin.konghq.com/uuid"
          },
          {
            "name": "JOIN",
            "type": "jq",
            "inputs": {
              "input1": "AUTHOR.body",
              "input2": "UUID.body"
            },
            "jq": "{\n  author: .input1.slideshow.author,\n  uuid: .input2.uuid,\n}\n"
          },
          {
            "name": "EXIT",
            "type": "exit",
            "inputs": {
              "body": "JOIN"
            },
            "status": 200
          }
        ]
      },
      "tags": []
    }
    '

Copied!

Make the following request:

curl -X POST https://{region}.api.konghq.com/v2/control-planes/{controlPlaneId}/core-entities/plugins/ \
    --header "accept: application/json" \
    --header "Content-Type: application/json" \
    --header "Authorization: Bearer $KONNECT_TOKEN" \
    --data '
    {
      "name": "datakit",
      "config": {
        "nodes": [
          {
            "name": "AUTHOR",
            "type": "call",
            "url": "https://httpbin.konghq.com/json"
          },
          {
            "name": "UUID",
            "type": "call",
            "url": "https://httpbin.konghq.com/uuid"
          },
          {
            "name": "JOIN",
            "type": "jq",
            "inputs": {
              "input1": "AUTHOR.body",
              "input2": "UUID.body"
            },
            "jq": "{\n  author: .input1.slideshow.author,\n  uuid: .input2.uuid,\n}\n"
          },
          {
            "name": "EXIT",
            "type": "exit",
            "inputs": {
              "body": "JOIN"
            },
            "status": 200
          }
        ]
      },
      "tags": []
    }
    '

Copied!

Make sure to replace the following placeholders with your own values:

region: Geographic region where your Kong Konnect is hosted and operates.
controlPlaneId: The id of the control plane.
KONNECT_TOKEN: Your Personal Access Token (PAT) associated with your Konnect account.

See the Konnect API reference to learn about region-specific URLs and personal access tokens.

echo "
apiVersion: configuration.konghq.com/v1
kind: KongClusterPlugin
metadata:
  name: datakit
  namespace: kong
  annotations:
    kubernetes.io/ingress.class: kong
    konghq.com/tags: ''
  labels:
    global: 'true'
config:
  nodes:
  - name: AUTHOR
    type: call
    url: https://httpbin.konghq.com/json
  - name: UUID
    type: call
    url: https://httpbin.konghq.com/uuid
  - name: JOIN
    type: jq
    inputs:
      input1: AUTHOR.body
      input2: UUID.body
    jq: |
      {
        author: .input1.slideshow.author,
        uuid: .input2.uuid,
      }
  - name: EXIT
    type: exit
    inputs:
      body: JOIN
    status: 200
plugin: datakit
" | kubectl apply -f -

Copied!

Prerequisite: Configure your Personal Access Token

terraform {
  required_providers {
    konnect = {
      source  = "kong/konnect"
    }
  }
}

provider "konnect" {
  personal_access_token = "$KONNECT_TOKEN"
  server_url            = "https://us.api.konghq.com/"
}

Copied!

Add the following to your Terraform configuration to create a Konnect Gateway Plugin:

resource "konnect_gateway_plugin_datakit" "my_datakit" {
  enabled = true

  config = {
    nodes = [
      {
        name = "AUTHOR"
        type = "call"
        url = "https://httpbin.konghq.com/json"
      }, 

      {
        name = "UUID"
        type = "call"
        url = "https://httpbin.konghq.com/uuid"
      }, 

      {
        name = "JOIN"
        type = "jq"

        inputs = {
          input1 = "AUTHOR.body"
          input2 = "UUID.body"
        }
        jq = <<EOF
{
  author: .input1.slideshow.author,
  uuid: .input2.uuid,
}
EOF
      }, 

      {
        name = "EXIT"
        type = "exit"

        inputs = {
          body = "JOIN"
        }
        status = 200
      }    ]
  }
  tags = []

  control_plane_id = konnect_gateway_control_plane.my_konnect_cp.id
}

Copied!

Add this section to your kong.yaml configuration file:

kong.yaml

Copied!

_format_version: "3.0"
plugins:
  - name: datakit
    service: serviceName|Id
    config:
      nodes:
      - name: AUTHOR
        type: call
        url: https://httpbin.konghq.com/json
      - name: UUID
        type: call
        url: https://httpbin.konghq.com/uuid
      - name: JOIN
        type: jq
        inputs:
          input1: AUTHOR.body
          input2: UUID.body
        jq: |
          {
            author: .input1.slideshow.author,
            uuid: .input2.uuid,
          }
      - name: EXIT
        type: exit
        inputs:
          body: JOIN
        status: 200

Make sure to replace the following placeholders with your own values:

serviceName|Id: The id or name of the service the plugin configuration will target.

Make the following request:

curl -i -X POST http://localhost:8001/services/{serviceName|Id}/plugins/ \
    --header "Accept: application/json" \
    --header "Content-Type: application/json" \
    --data '
    {
      "name": "datakit",
      "config": {
        "nodes": [
          {
            "name": "AUTHOR",
            "type": "call",
            "url": "https://httpbin.konghq.com/json"
          },
          {
            "name": "UUID",
            "type": "call",
            "url": "https://httpbin.konghq.com/uuid"
          },
          {
            "name": "JOIN",
            "type": "jq",
            "inputs": {
              "input1": "AUTHOR.body",
              "input2": "UUID.body"
            },
            "jq": "{\n  author: .input1.slideshow.author,\n  uuid: .input2.uuid,\n}\n"
          },
          {
            "name": "EXIT",
            "type": "exit",
            "inputs": {
              "body": "JOIN"
            },
            "status": 200
          }
        ]
      },
      "tags": []
    }
    '

Copied!

Make sure to replace the following placeholders with your own values:

serviceName|Id: The id or name of the service the plugin configuration will target.

Make the following request:

curl -X POST https://{region}.api.konghq.com/v2/control-planes/{controlPlaneId}/core-entities/services/{serviceId}/plugins/ \
    --header "accept: application/json" \
    --header "Content-Type: application/json" \
    --header "Authorization: Bearer $KONNECT_TOKEN" \
    --data '
    {
      "name": "datakit",
      "config": {
        "nodes": [
          {
            "name": "AUTHOR",
            "type": "call",
            "url": "https://httpbin.konghq.com/json"
          },
          {
            "name": "UUID",
            "type": "call",
            "url": "https://httpbin.konghq.com/uuid"
          },
          {
            "name": "JOIN",
            "type": "jq",
            "inputs": {
              "input1": "AUTHOR.body",
              "input2": "UUID.body"
            },
            "jq": "{\n  author: .input1.slideshow.author,\n  uuid: .input2.uuid,\n}\n"
          },
          {
            "name": "EXIT",
            "type": "exit",
            "inputs": {
              "body": "JOIN"
            },
            "status": 200
          }
        ]
      },
      "tags": []
    }
    '

Copied!

Make sure to replace the following placeholders with your own values:

region: Geographic region where your Kong Konnect is hosted and operates.
controlPlaneId: The id of the control plane.
KONNECT_TOKEN: Your Personal Access Token (PAT) associated with your Konnect account.
serviceId: The id of the service the plugin configuration will target.

See the Konnect API reference to learn about region-specific URLs and personal access tokens.

echo "
apiVersion: configuration.konghq.com/v1
kind: KongPlugin
metadata:
  name: datakit
  namespace: kong
  annotations:
    kubernetes.io/ingress.class: kong
    konghq.com/tags: ''
config:
  nodes:
  - name: AUTHOR
    type: call
    url: https://httpbin.konghq.com/json
  - name: UUID
    type: call
    url: https://httpbin.konghq.com/uuid
  - name: JOIN
    type: jq
    inputs:
      input1: AUTHOR.body
      input2: UUID.body
    jq: |
      {
        author: .input1.slideshow.author,
        uuid: .input2.uuid,
      }
  - name: EXIT
    type: exit
    inputs:
      body: JOIN
    status: 200
plugin: datakit
" | kubectl apply -f -

Copied!

Next, apply the KongPlugin resource by annotating the service resource:

kubectl annotate -n kong service SERVICE_NAME konghq.com/plugins=datakit

Copied!

Prerequisite: Configure your Personal Access Token

terraform {
  required_providers {
    konnect = {
      source  = "kong/konnect"
    }
  }
}

provider "konnect" {
  personal_access_token = "$KONNECT_TOKEN"
  server_url            = "https://us.api.konghq.com/"
}

Copied!

Add the following to your Terraform configuration to create a Konnect Gateway Plugin:

resource "konnect_gateway_plugin_datakit" "my_datakit" {
  enabled = true

  config = {
    nodes = [
      {
        name = "AUTHOR"
        type = "call"
        url = "https://httpbin.konghq.com/json"
      }, 

      {
        name = "UUID"
        type = "call"
        url = "https://httpbin.konghq.com/uuid"
      }, 

      {
        name = "JOIN"
        type = "jq"

        inputs = {
          input1 = "AUTHOR.body"
          input2 = "UUID.body"
        }
        jq = <<EOF
{
  author: .input1.slideshow.author,
  uuid: .input2.uuid,
}
EOF
      }, 

      {
        name = "EXIT"
        type = "exit"

        inputs = {
          body = "JOIN"
        }
        status = 200
      }    ]
  }
  tags = []

  control_plane_id = konnect_gateway_control_plane.my_konnect_cp.id
  service = {
    id = konnect_gateway_service.my_service.id
  }
}

Copied!

Add this section to your kong.yaml configuration file:

kong.yaml

Copied!

_format_version: "3.0"
plugins:
  - name: datakit
    route: routeName|Id
    config:
      nodes:
      - name: AUTHOR
        type: call
        url: https://httpbin.konghq.com/json
      - name: UUID
        type: call
        url: https://httpbin.konghq.com/uuid
      - name: JOIN
        type: jq
        inputs:
          input1: AUTHOR.body
          input2: UUID.body
        jq: |
          {
            author: .input1.slideshow.author,
            uuid: .input2.uuid,
          }
      - name: EXIT
        type: exit
        inputs:
          body: JOIN
        status: 200

Make sure to replace the following placeholders with your own values:

routeName|Id: The id or name of the route the plugin configuration will target.

Make the following request:

curl -i -X POST http://localhost:8001/routes/{routeName|Id}/plugins/ \
    --header "Accept: application/json" \
    --header "Content-Type: application/json" \
    --data '
    {
      "name": "datakit",
      "config": {
        "nodes": [
          {
            "name": "AUTHOR",
            "type": "call",
            "url": "https://httpbin.konghq.com/json"
          },
          {
            "name": "UUID",
            "type": "call",
            "url": "https://httpbin.konghq.com/uuid"
          },
          {
            "name": "JOIN",
            "type": "jq",
            "inputs": {
              "input1": "AUTHOR.body",
              "input2": "UUID.body"
            },
            "jq": "{\n  author: .input1.slideshow.author,\n  uuid: .input2.uuid,\n}\n"
          },
          {
            "name": "EXIT",
            "type": "exit",
            "inputs": {
              "body": "JOIN"
            },
            "status": 200
          }
        ]
      },
      "tags": []
    }
    '

Copied!

Make sure to replace the following placeholders with your own values:

routeName|Id: The id or name of the route the plugin configuration will target.

Make the following request:

curl -X POST https://{region}.api.konghq.com/v2/control-planes/{controlPlaneId}/core-entities/routes/{routeId}/plugins/ \
    --header "accept: application/json" \
    --header "Content-Type: application/json" \
    --header "Authorization: Bearer $KONNECT_TOKEN" \
    --data '
    {
      "name": "datakit",
      "config": {
        "nodes": [
          {
            "name": "AUTHOR",
            "type": "call",
            "url": "https://httpbin.konghq.com/json"
          },
          {
            "name": "UUID",
            "type": "call",
            "url": "https://httpbin.konghq.com/uuid"
          },
          {
            "name": "JOIN",
            "type": "jq",
            "inputs": {
              "input1": "AUTHOR.body",
              "input2": "UUID.body"
            },
            "jq": "{\n  author: .input1.slideshow.author,\n  uuid: .input2.uuid,\n}\n"
          },
          {
            "name": "EXIT",
            "type": "exit",
            "inputs": {
              "body": "JOIN"
            },
            "status": 200
          }
        ]
      },
      "tags": []
    }
    '

Copied!

Make sure to replace the following placeholders with your own values:

region: Geographic region where your Kong Konnect is hosted and operates.
controlPlaneId: The id of the control plane.
KONNECT_TOKEN: Your Personal Access Token (PAT) associated with your Konnect account.
routeId: The id of the route the plugin configuration will target.

See the Konnect API reference to learn about region-specific URLs and personal access tokens.

echo "
apiVersion: configuration.konghq.com/v1
kind: KongPlugin
metadata:
  name: datakit
  namespace: kong
  annotations:
    kubernetes.io/ingress.class: kong
    konghq.com/tags: ''
config:
  nodes:
  - name: AUTHOR
    type: call
    url: https://httpbin.konghq.com/json
  - name: UUID
    type: call
    url: https://httpbin.konghq.com/uuid
  - name: JOIN
    type: jq
    inputs:
      input1: AUTHOR.body
      input2: UUID.body
    jq: |
      {
        author: .input1.slideshow.author,
        uuid: .input2.uuid,
      }
  - name: EXIT
    type: exit
    inputs:
      body: JOIN
    status: 200
plugin: datakit
" | kubectl apply -f -

Copied!

Next, apply the KongPlugin resource by annotating the httproute or ingress resource:

kubectl annotate -n kong httproute  konghq.com/plugins=datakit

Copied!

kubectl annotate -n kong ingress  konghq.com/plugins=datakit

Copied!

Prerequisite: Configure your Personal Access Token

terraform {
  required_providers {
    konnect = {
      source  = "kong/konnect"
    }
  }
}

provider "konnect" {
  personal_access_token = "$KONNECT_TOKEN"
  server_url            = "https://us.api.konghq.com/"
}

Copied!

Add the following to your Terraform configuration to create a Konnect Gateway Plugin:

resource "konnect_gateway_plugin_datakit" "my_datakit" {
  enabled = true

  config = {
    nodes = [
      {
        name = "AUTHOR"
        type = "call"
        url = "https://httpbin.konghq.com/json"
      }, 

      {
        name = "UUID"
        type = "call"
        url = "https://httpbin.konghq.com/uuid"
      }, 

      {
        name = "JOIN"
        type = "jq"

        inputs = {
          input1 = "AUTHOR.body"
          input2 = "UUID.body"
        }
        jq = <<EOF
{
  author: .input1.slideshow.author,
  uuid: .input2.uuid,
}
EOF
      }, 

      {
        name = "EXIT"
        type = "exit"

        inputs = {
          body = "JOIN"
        }
        status = 200
      }    ]
  }
  tags = []

  control_plane_id = konnect_gateway_control_plane.my_konnect_cp.id
  route = {
    id = konnect_gateway_route.my_route.id
  }
}

Copied!

Add this section to your kong.yaml configuration file:

kong.yaml

Copied!

_format_version: "3.0"
plugins:
  - name: datakit
    consumer: consumerName|Id
    config:
      nodes:
      - name: AUTHOR
        type: call
        url: https://httpbin.konghq.com/json
      - name: UUID
        type: call
        url: https://httpbin.konghq.com/uuid
      - name: JOIN
        type: jq
        inputs:
          input1: AUTHOR.body
          input2: UUID.body
        jq: |
          {
            author: .input1.slideshow.author,
            uuid: .input2.uuid,
          }
      - name: EXIT
        type: exit
        inputs:
          body: JOIN
        status: 200

Make sure to replace the following placeholders with your own values:

consumerName|Id: The id or name of the consumer the plugin configuration will target.

Make the following request:

curl -i -X POST http://localhost:8001/consumers/{consumerName|Id}/plugins/ \
    --header "Accept: application/json" \
    --header "Content-Type: application/json" \
    --data '
    {
      "name": "datakit",
      "config": {
        "nodes": [
          {
            "name": "AUTHOR",
            "type": "call",
            "url": "https://httpbin.konghq.com/json"
          },
          {
            "name": "UUID",
            "type": "call",
            "url": "https://httpbin.konghq.com/uuid"
          },
          {
            "name": "JOIN",
            "type": "jq",
            "inputs": {
              "input1": "AUTHOR.body",
              "input2": "UUID.body"
            },
            "jq": "{\n  author: .input1.slideshow.author,\n  uuid: .input2.uuid,\n}\n"
          },
          {
            "name": "EXIT",
            "type": "exit",
            "inputs": {
              "body": "JOIN"
            },
            "status": 200
          }
        ]
      },
      "tags": []
    }
    '

Copied!

Make sure to replace the following placeholders with your own values:

consumerName|Id: The id or name of the consumer the plugin configuration will target.

Make the following request:

curl -X POST https://{region}.api.konghq.com/v2/control-planes/{controlPlaneId}/core-entities/consumers/{consumerId}/plugins/ \
    --header "accept: application/json" \
    --header "Content-Type: application/json" \
    --header "Authorization: Bearer $KONNECT_TOKEN" \
    --data '
    {
      "name": "datakit",
      "config": {
        "nodes": [
          {
            "name": "AUTHOR",
            "type": "call",
            "url": "https://httpbin.konghq.com/json"
          },
          {
            "name": "UUID",
            "type": "call",
            "url": "https://httpbin.konghq.com/uuid"
          },
          {
            "name": "JOIN",
            "type": "jq",
            "inputs": {
              "input1": "AUTHOR.body",
              "input2": "UUID.body"
            },
            "jq": "{\n  author: .input1.slideshow.author,\n  uuid: .input2.uuid,\n}\n"
          },
          {
            "name": "EXIT",
            "type": "exit",
            "inputs": {
              "body": "JOIN"
            },
            "status": 200
          }
        ]
      },
      "tags": []
    }
    '

Copied!

Make sure to replace the following placeholders with your own values:

region: Geographic region where your Kong Konnect is hosted and operates.
controlPlaneId: The id of the control plane.
KONNECT_TOKEN: Your Personal Access Token (PAT) associated with your Konnect account.
consumerId: The id of the consumer the plugin configuration will target.

See the Konnect API reference to learn about region-specific URLs and personal access tokens.

echo "
apiVersion: configuration.konghq.com/v1
kind: KongPlugin
metadata:
  name: datakit
  namespace: kong
  annotations:
    kubernetes.io/ingress.class: kong
    konghq.com/tags: ''
config:
  nodes:
  - name: AUTHOR
    type: call
    url: https://httpbin.konghq.com/json
  - name: UUID
    type: call
    url: https://httpbin.konghq.com/uuid
  - name: JOIN
    type: jq
    inputs:
      input1: AUTHOR.body
      input2: UUID.body
    jq: |
      {
        author: .input1.slideshow.author,
        uuid: .input2.uuid,
      }
  - name: EXIT
    type: exit
    inputs:
      body: JOIN
    status: 200
plugin: datakit
" | kubectl apply -f -

Copied!

Next, apply the KongPlugin resource by annotating the KongConsumer resource:

kubectl annotate -n kong  CONSUMER_NAME konghq.com/plugins=datakit

Copied!

Prerequisite: Configure your Personal Access Token

terraform {
  required_providers {
    konnect = {
      source  = "kong/konnect"
    }
  }
}

provider "konnect" {
  personal_access_token = "$KONNECT_TOKEN"
  server_url            = "https://us.api.konghq.com/"
}

Copied!

Add the following to your Terraform configuration to create a Konnect Gateway Plugin:

resource "konnect_gateway_plugin_datakit" "my_datakit" {
  enabled = true

  config = {
    nodes = [
      {
        name = "AUTHOR"
        type = "call"
        url = "https://httpbin.konghq.com/json"
      }, 

      {
        name = "UUID"
        type = "call"
        url = "https://httpbin.konghq.com/uuid"
      }, 

      {
        name = "JOIN"
        type = "jq"

        inputs = {
          input1 = "AUTHOR.body"
          input2 = "UUID.body"
        }
        jq = <<EOF
{
  author: .input1.slideshow.author,
  uuid: .input2.uuid,
}
EOF
      }, 

      {
        name = "EXIT"
        type = "exit"

        inputs = {
          body = "JOIN"
        }
        status = 200
      }    ]
  }
  tags = []

  control_plane_id = konnect_gateway_control_plane.my_konnect_cp.id
  consumer = {
    id = konnect_gateway_consumer.my_consumer.id
  }
}

Copied!

Add this section to your kong.yaml configuration file:

kong.yaml

Copied!

_format_version: "3.0"
plugins:
  - name: datakit
    consumer_group: consumerGroupName|Id
    config:
      nodes:
      - name: AUTHOR
        type: call
        url: https://httpbin.konghq.com/json
      - name: UUID
        type: call
        url: https://httpbin.konghq.com/uuid
      - name: JOIN
        type: jq
        inputs:
          input1: AUTHOR.body
          input2: UUID.body
        jq: |
          {
            author: .input1.slideshow.author,
            uuid: .input2.uuid,
          }
      - name: EXIT
        type: exit
        inputs:
          body: JOIN
        status: 200

Make sure to replace the following placeholders with your own values:

consumerGroupName|Id: The id or name of the consumer group the plugin configuration will target.

Make the following request:

curl -i -X POST http://localhost:8001/consumer_groups/{consumerGroupName|Id}/plugins/ \
    --header "Accept: application/json" \
    --header "Content-Type: application/json" \
    --data '
    {
      "name": "datakit",
      "config": {
        "nodes": [
          {
            "name": "AUTHOR",
            "type": "call",
            "url": "https://httpbin.konghq.com/json"
          },
          {
            "name": "UUID",
            "type": "call",
            "url": "https://httpbin.konghq.com/uuid"
          },
          {
            "name": "JOIN",
            "type": "jq",
            "inputs": {
              "input1": "AUTHOR.body",
              "input2": "UUID.body"
            },
            "jq": "{\n  author: .input1.slideshow.author,\n  uuid: .input2.uuid,\n}\n"
          },
          {
            "name": "EXIT",
            "type": "exit",
            "inputs": {
              "body": "JOIN"
            },
            "status": 200
          }
        ]
      },
      "tags": []
    }
    '

Copied!

Make sure to replace the following placeholders with your own values:

consumerGroupName|Id: The id or name of the consumer group the plugin configuration will target.

Make the following request:

curl -X POST https://{region}.api.konghq.com/v2/control-planes/{controlPlaneId}/core-entities/consumer_groups/{consumerGroupId}/plugins/ \
    --header "accept: application/json" \
    --header "Content-Type: application/json" \
    --header "Authorization: Bearer $KONNECT_TOKEN" \
    --data '
    {
      "name": "datakit",
      "config": {
        "nodes": [
          {
            "name": "AUTHOR",
            "type": "call",
            "url": "https://httpbin.konghq.com/json"
          },
          {
            "name": "UUID",
            "type": "call",
            "url": "https://httpbin.konghq.com/uuid"
          },
          {
            "name": "JOIN",
            "type": "jq",
            "inputs": {
              "input1": "AUTHOR.body",
              "input2": "UUID.body"
            },
            "jq": "{\n  author: .input1.slideshow.author,\n  uuid: .input2.uuid,\n}\n"
          },
          {
            "name": "EXIT",
            "type": "exit",
            "inputs": {
              "body": "JOIN"
            },
            "status": 200
          }
        ]
      },
      "tags": []
    }
    '

Copied!

Make sure to replace the following placeholders with your own values:

region: Geographic region where your Kong Konnect is hosted and operates.
controlPlaneId: The id of the control plane.
KONNECT_TOKEN: Your Personal Access Token (PAT) associated with your Konnect account.
consumerGroupId: The id of the consumer group the plugin configuration will target.

See the Konnect API reference to learn about region-specific URLs and personal access tokens.

echo "
apiVersion: configuration.konghq.com/v1
kind: KongPlugin
metadata:
  name: datakit
  namespace: kong
  annotations:
    kubernetes.io/ingress.class: kong
    konghq.com/tags: ''
config:
  nodes:
  - name: AUTHOR
    type: call
    url: https://httpbin.konghq.com/json
  - name: UUID
    type: call
    url: https://httpbin.konghq.com/uuid
  - name: JOIN
    type: jq
    inputs:
      input1: AUTHOR.body
      input2: UUID.body
    jq: |
      {
        author: .input1.slideshow.author,
        uuid: .input2.uuid,
      }
  - name: EXIT
    type: exit
    inputs:
      body: JOIN
    status: 200
plugin: datakit
" | kubectl apply -f -

Copied!

Next, apply the KongPlugin resource by annotating the KongConsumerGroup resource:

kubectl annotate -n kong  CONSUMERGROUP_NAME konghq.com/plugins=datakit

Copied!

Prerequisite: Configure your Personal Access Token

terraform {
  required_providers {
    konnect = {
      source  = "kong/konnect"
    }
  }
}

provider "konnect" {
  personal_access_token = "$KONNECT_TOKEN"
  server_url            = "https://us.api.konghq.com/"
}

Copied!

Add the following to your Terraform configuration to create a Konnect Gateway Plugin:

resource "konnect_gateway_plugin_datakit" "my_datakit" {
  enabled = true

  config = {
    nodes = [
      {
        name = "AUTHOR"
        type = "call"
        url = "https://httpbin.konghq.com/json"
      }, 

      {
        name = "UUID"
        type = "call"
        url = "https://httpbin.konghq.com/uuid"
      }, 

      {
        name = "JOIN"
        type = "jq"

        inputs = {
          input1 = "AUTHOR.body"
          input2 = "UUID.body"
        }
        jq = <<EOF
{
  author: .input1.slideshow.author,
  uuid: .input2.uuid,
}
EOF
      }, 

      {
        name = "EXIT"
        type = "exit"

        inputs = {
          body = "JOIN"
        }
        status = 200
      }    ]
  }
  tags = []

  control_plane_id = konnect_gateway_control_plane.my_konnect_cp.id
  consumer_group = {
    id = konnect_gateway_consumer_group.my_consumer_group.id
  }
}

Copied!

Datakit

Combine multiple API responsesv3.11+

Set up the plugin

Help us make these docs great!

Still need help