Contact UsGet started
© 2024 Iron Hive LLC Belgrade

Getting started with EventRouter

Written by
Updated at November 18, 2024

Note

EventRouter is at the Preview stage. To get access, contact support or your account manager.

In this guide, you will create a queue in Message Queue and send a message to it. This message will be transmitted to a Cloud Functions function via a bus.

Getting started

To get started in Yandex Cloud:

  1. Log in to the management console. If not signed up yet, navigate to the management console and follow the instructions.
  2. On the Billing page, make sure you have a billing account linked and it has the ACTIVE or TRIAL_ACTIVE status. If you do not have a billing account yet, create one.
  3. If you do not have a folder yet, create one.

Create a service account

  1. In the management console, select the appropriate folder.
  2. In the list of services, select Identity and Access Management.
  3. Click Create service account.
  4. Enter a name for the service account: sa-for-eventrouter.
  5. Click Add role and select the functions.functionInvoker, ymq.reader, and ymq.writer roles.
  6. Click Create.

Create a queue

  1. In the management console, select Message Queue.
  2. Click Create queue.
  3. Enter a name for the queue: sample-queue.
  4. Select the Standard type. Do not change other settings.
  5. Click Create.
  6. Open the queue you created.
  7. On the Overview tab under General information, copy the queue URL and ARN for later use.

Create a function

  1. In the management console, select Cloud Functions.
  2. Create a function:
    1. In the top-right corner, click Create function.
    2. Enter the function name: eventrouter-function.
    3. Click Create.
  3. Create a function version:
    1. In the Editor window that opens, select Node.js 18.
    2. Disable the Add files with code examples option.
    3. Click Continue.
    4. Create a file named index.js and paste the following code into it: 
      module.exports.handler = async function (event, context) {
    console.log(JSON.stringify(event))
    return {
        statusCode: 200,
        body: "",
    };
};
    5. Under Parameters, specify the following in the field:
      • Entry point: index.handler
      • Service account: sa-for-eventrouter
    6. Click Save changes.

Create a bus

  1. In the management console, select Serverless Integrations.
  2. Go to the EventRouter tab.
  3. In the top-right corner, click Create bus.
  4. Enter a name for the bus and click Create.

Create a connector

  1. Select a bus.
  2. Go to the Connectors tab.
  3. In the top-right corner, click Create connector.
  4. Under Source, select Yandex Message Queue.
  5. Specify the queue ARN in the Message queue field.
  6. In the Service account field, specify sa-for-eventrouter.
  7. Click Create.

Create a rule

  1. Select a bus.
  2. Go to the Rules tab.
  3. In the top-right corner, click Create rule.
  4. Under Targets, click Add.
  5. In the Type field, select Yandex Cloud Functions.
  6. In the Function field, specify eventrouter-function.
  7. In the Service account field, specify sa-for-eventrouter.
  8. Click Create.

Send a message to the queue

  1. Install the AWS CLI.

  2. Create static access keys for the sa-for-eventrouter service account. Save the ID and secret key to a secure location. You will not be able to view the secret key parameters again after you close the window.

  3. Set up the AWS CLI:

    1. Launch the interactive profile setup:

      aws configure

    2. Specify the service account key ID you obtained earlier:

      AWS Access Key ID [****************ver_]: <service_account_key_ID>

    3. Specify the service account secret key you obtained earlier:

      AWS Secret Access Key [****************w5lb]: <service_account_secret_key>

    4. Specify the ru-central1 default region name:

      Default region name [ru-central1]: ru-central1

    5. Specify json as the default format for output data:

      Default output format [None]: json

    6. To view the current profile settings, run this command:

      aws configure list

      Result:

            Name                    Value             Type    Location
      ----                    -----             ----    --------
   profile                <not set>             None    None
access_key     ****************aBc1 shared-credentials-file
secret_key     ****************DeF2 shared-credentials-file
    region              ru-central1      config-file    ~/.aws/config

  4. Send a message to sample-queue using the previously saved queue URL:

     aws sqs send-message \
   --message-body "Hello World" \
   --endpoint https://message-queue.api.cloud.yandex.net/ \
   --queue-url <queue_URL>

    Result:

    {
    "MD5OfMessageBody": "67e63db14341b5a696596634********",
    "MessageId": "765ff4d2-fa4bc83-6cfcc***-*****"
}

Check that the function was invoked

  1. In the management console, select Cloud Functions.
  2. Select the eventrouter-function function.
  3. Go to the Logs tab. The messages you sent to the queue must appear in logs.

What's next

Previous
Workflows
Next
Overview