Page tree
Skip to end of metadata
Go to start of metadata

Description

In this article, you will learn how to send API requests using RabbitMQ.

A unique parameter request_id is sent to identify requests.

Queues

When working with API in RabbitMQ, two queues are used:

  1. api_req - queue for incoming requests;
  2. api_resp - the queue that receives responses to requests (only if request_id is specified).

Structure of the sent JSON message

Parameter

Type

Example

Required

Required

request_idstring"abcd1234"Yes, if the response to the request is necessaryRequest ID
requeststring
api/v1.1/campaigns/triggers/import_and_start_batch



YesAPI request path
bodyJSON object

"body": {
    "data":
        {
            "_fname": "Fname1",
            "_lname": "Lname1",
            "email": "profile1@example.com"
        },
    "email": "profile1@example.com",
    "db_id": 1,
    "detect_geo": true,
    "token": "abcdefghijklmnopqrstuvwxyzABCD"
}



YesAPI request body

Structure of the received JSON message

Parameter

Type

Example

Required

bodyJSON object

"body":
    {
        "error":0,
        "error_text":"Successful operation",
        "profile_id":"60f039e830b8bcb28392f8eb"
    }

Request response body
request_idstring"abcd1234"Request ID

How to send API requests in Go

You can send an API request using a script that calls RabbitMQ:

  • Write and execute a script
Example


package main

import (
	"encoding/json"
	"log"

	"github.com/streadway/amqp"
)

const accID = 1
const resourceID = 3
const dbID = 23
const msgID = 17
const segmentID = 85
const amountOfPushMsgs = 1
const emailDomain = "example.com"

const req = `{
	"account_id": 1,
	"request_id": "db1894e4-1a2c-4021-8233-9cca0b96b79e",
	"request": "api/v1.1/campaigns/triggers/import_and_start_batch",
    "body": {
		"token": "abcdefghijklmnopqrstuvwxyzABC"
		"format": "json",
		"trigger_id": 240,
		"skip_triggers": false,
		"detect_geo": true,
		"matching": "custom",
		"field_name":"CustomF",

		"custom_data":{
			"some":"some0"
		},
		"content":{
			"someCont":"someCont0"
		},
		"data": [
			{
				"data":{
					"_fname":"NUMBER13",
					"_lname":"Lambert",
					"phones":"790000000013",
					"email": "profile1@example.com",
					"CustomF":18
				},
				"custom_data":{
					"some":"some1"
				},
				"content":{
					"someCont":"someCont1"
				}
			},
			{
				"data":{
					"_fname":"NUMBER14",
					"_lname":"Hard",
					"phones":"790000000014",
					"email": "profile2@example.com",
					"CustomF":14
				}
			}
		]
	}
}`

func failOnError(err error, msg string) {
	if err != nil {
		log.Fatalf("%s: %s", msg, err)
	}
}

func main() {
	var err error

	var conn *amqp.Connection
	conn, err = amqp.Dial("amqp://example:abcdefghijklmnopqrstuvwxyz127.0.0.1:5672/")
	failOnError(err, "Failed to connect to RabbitMQ")
	defer conn.Close()

	var ch *amqp.Channel
	ch, err = conn.Channel()
	failOnError(err, "Failed to open RabbitMQ channel")
	defer ch.Close()

	qUeueImport, err := ch.QueueDeclare(
		"api_req", // name
		true,      // durable
		false,     // delete when unused
		false,     // exclusive
		false,     // no-wait
		nil,       // arguments
	)
	failOnError(err, "Failed to declare RabbitMQ queue")

	for i := 0; i < amountOfPushMsgs; i++ {
		var bodyMap = make(map[string]interface{})
		err = json.Unmarshal([]byte(req), &bodyMap)
		failOnError(err, "Failed json.Unmarshal to bodyMap")

		for k, v := range bodyMap {
			log.Println(k, v)
		}

		body, err := json.Marshal(bodyMap)
		failOnError(err, "Failed to json.Marshal bodyMap")

		err = ch.Publish(
			"",               // exchange
			qUeueImport.Name, // routing key
			false,            // mandatory
			false,            // immediate
			amqp.Publishing{
				ContentType: "text/plain",
				Body:        []byte(body),
			})
		failOnError(err, "Failed to publish a message")
	}

	log.Printf("[v] Sended %d requests to %s", amountOfPushMsgs, qUeueImport.Name)
}
  • After executing the script, go to RabbitMQ → Queues

  • Choose api_resp  and get a response to the API request

How to send API requests via RabbitMQ Management Plugin

You can send an API request directly to RabbitMQ via api_req:

  • Go to RabbitMQ → the Queues tab. Then select api_req and Publish message.

  • After the request is sent, you can see its result in the same way as in the first method.
  • No labels