Creating a rule with a Yandex Message Queue target
-
In the management console
, select the folder where you want to create a rule. -
Select Serverless Integrations.
-
In the left-hand panel, click
EventRouter. -
Select the bus you need.
-
Navigate to the
Rules tab. -
In the top-right corner, click Create rule.
-
Optionally, expand the Filter section and enter a jq expression
to filter events. -
Under Targets, click Add and configure the target:
- Specify
Yandex Message Queue
as the target type. - Select the folder and queue to receive the messages matching the rule.
- Select the service account to which the
ymq.writer
role or higher is assigned for the selected queue or create a new account. -
Optionally, click
Message retry settings and specify the following:- Number of retries: Number of message retries before EventRouter moves the messages to the dead-letter queue (DLQ). Valid values range from 0 to 1,000. The default value is 3.
- Interval: Time, in hours, before a retry attempt to send the messages if the current attempt fails. Valid values range from 0 to 60 hours. The default value is 10.
-
(Optional) Open the Transformer field and enter a jq template
to transform events. If no template is specified, the event will not be transformed. -
(Optional) Expand the Dead Letter settings section:
- Specify
-
Expand Additional parameters:
-
Specify the rule name and description. Follow these naming requirements:
- The name must be from 3 to 63 characters long.
- It may contain uppercase and lowercase Latin and Russian letters, numbers, hyphens, underscores, and spaces.
- The first character must be a letter. The last character cannot be a hyphen, underscore, or space.
-
Optionally, add labels:
- Click Add label.
- Enter a label in
key: value
format. - Press Enter.
-
Optionally, enable deletion protection. You cannot delete a rule with this option enabled.
-
-
Click Create.
If you do not have the Yandex Cloud CLI yet, install and initialize it.
The folder specified in the CLI profile is used by default. You can specify a different folder using the --folder-name
or --folder-id
parameters.
-
See the description of the CLI command for creating a rule:
yc serverless eventrouter rule create --help
-
Create a rule with a Yandex Message Queue target:
yc serverless eventrouter rule create \ --bus-id <bus_ID> \ --filter '<jq_expression>' \ --ymq-target \ queue-arn=<queue_ARN>,\ service-account-id=<queue_service_account_ID>,\ retry-attempts=<number_of_attempts>,\ maximum-age=<interval>,\ transformer=<jq_template>,\ dlq-arn=<DLQ>,\ dlq-service-account-id=<DLQ_service_account_ID> \ --name <rule_name> \ --description "<rule_description>" \ --deletion-protection \ --labels <label_list>
Where:
--bus-id
: EventRouter bus ID.--filter
: jq expression for event filtering.
-
--ymq-target
: Flag to configure theYandex Message Queue
target and its parameters:queue-arn
: ARN of the queue to receive the messages matching the rule.service-account-id
: ID of the service account to which theymq.writer
role or higher is assigned for the selected queue.
retry-attempts
: Number of message retries before EventRouter moves the messages to the dead-letter queue (DLQ). Valid values range from 0 to 1,000. This is an optional parameter.maximum-age
: Time interval before a retry attempt to send the messages if the current attempt fails. Valid values range from 0 to 60 hours. This is an optional parameter.
transformer
: jq template to transform events. If no template is specified, the event will not be transformed. This is an optional parameter.
dlq-arn
: ARN of the DLQ to which messages that the target could not process will be redirected. This is an optional parameter.dlq-service-account-id
: ID of the service account to which theymq.writer
role or higher is assigned for the selected DLQ. This is an optional parameter.
-
--name
: Rule name. Follow these naming requirements:- The name must be from 3 to 63 characters long.
- It may contain uppercase and lowercase Latin and Russian letters, numbers, hyphens, underscores, and spaces.
- The first character must be a letter. The last character cannot be a hyphen, underscore, or space.
-
--description
: Rule description. This is an optional parameter. -
--deletion-protection
: Rule deletion protection. By default, protection is disabled. You cannot delete a rule with this option enabled. To disable deletion protection, specify--no-deletion-protection
. This is an optional parameter. -
--labels
: List of labels. This is an optional parameter.You can specify one or more labels separated by commas in
<key1>=<value1>,<key2>=<value2>
format.
Result:
id: f66vfpjrkc35******** bus_id: f66epjc9llqt******** folder_id: b1g681qpemb4******** cloud_id: b1gia87mbaom******** created_at: "2025-02-26T14:04:47.710918Z" name: new-rule description: created via cli labels: owner: admin version: beta filter: jq_filter: .firstName == "Ivan" targets: - ymq: queue_arn: yrn:yc:ymq:ru-central1:b1g681qpemb4********:dlq-42 service_account_id: ajelprpohp7r******** transformer: jq_transformer: . retry_settings: retry_attempts: "3" maximum_age: 600s dead_letter_queue: queue_arn: yrn:yc:ymq:ru-central1:b1g681qpemb4********:dlq-42 service_account_id: ajelprpohp7r******** status: ENABLED deletion_protection: true status: ENABLED
With Terraform
Terraform is distributed under the Business Source License
For more information about the provider resources, see the documentation on the Terraform
If you don't have Terraform, install it and configure the Yandex Cloud provider.
To create a rule with a Yandex Message Queue target:
-
In the configuration file, define the parameters of the resources you want to create:
resource "yandex_serverless_eventrouter_rule" "example_rule" { bus_id = "<bus_ID>" jq_filter = "<jq_expression>" ymq { queue_arn = "<queue_ARN>" service_account_id = "<service_account_ID>" } name = "<rule_name>" description = "<rule_description>" labels = { <key_1> = "<value_1>" <key_2> = "<value_2>" ... <key_n> = "<value_n>" } }
Where:
-
bus_id
: EventRouter bus ID. -
jq_filter
: jq expression for event filtering. -
ymq
: Section to configure theYandex Message Queue
target and its parameters:queue_arn
: ARN of the queue to receive the messages matching the rule.service_account_id
: ID of the service account to which theymq.writer
role or higher is assigned for the selected queue.
-
name
: Rule name. The naming requirements are as follows:- The name must be from 3 to 63 characters long.
- It may contain uppercase and lowercase Latin and Russian letters, numbers, hyphens, underscores, and spaces.
- The first character must be a letter. The last character cannot be a hyphen, underscore, or space.
-
description
: Rule description. This is an optional parameter. -
labels
: List of labels. Provide labels in<key> = "<value>"
format. This is an optional parameter.
For more information about the
yandex_serverless_eventrouter_rule
resource parameters, see this Terraform article . -
-
Create the resources:
-
In the terminal, change to the folder where you edited the configuration file.
-
Make sure the configuration file is correct using the command:
terraform validate
If the configuration is correct, the following message is returned:
Success! The configuration is valid.
-
Run the command:
terraform plan
The terminal will display a list of resources with parameters. No changes are made at this step. If the configuration contains errors, Terraform will point them out.
-
Apply the configuration changes:
terraform apply
-
Confirm the changes: type
yes
in the terminal and press Enter.
Terraform will create all the required resources. You can check the new resources using the management console
or this CLI command:yc serverless eventrouter rule list
-
To create a rule with a Yandex Message Queue target, use the Create REST API method for the rule resource or the rule/Create gRPC API call.
All newly created rules are enabled by default. To stop events matching the rule from being routed to the target, disable the rule.