Amazon Simple Queue Service (SQS) — это полностью управляемый сервис очередей сообщений, который позволяет вам разделять и масштабировать микросервисы, распределенные системы и бессерверные приложения. SQS устраняет сложность и накладные расходы, связанные с управлением и эксплуатацией промежуточного программного обеспечения для обмена сообщениями, и позволяет разработчикам сосредоточиться на дифференцирующей работе.
С помощью Amazon SQS вы можете:
- Отправлять сообщения: Публиковать сообщения в очередях для асинхронной обработки
- Разделять приложения: Обеспечивать слабую связь между компонентами вашей системы
- Масштабировать рабочие нагрузки: Обрабатывать переменные рабочие нагрузки без подготовки инфраструктуры
- Обеспечивать надежность: Встроенная избыточность и высокая доступность
- Поддерживать очереди FIFO: Поддерживать строгий порядок сообщений и обработку ровно один раз
В AACFlow интеграция с SQS позволяет вашим агентам безопасно и программно отправлять сообщения в очереди Amazon SQS. Поддерживаемые операции включают:
- Отправка сообщения: Отправлять сообщения в очереди SQS с необязательным идентификатором группы сообщений и идентификатором дедупликации для очередей FIFO
Эта интеграция позволяет вашим агентам автоматизировать рабочие процессы отправки сообщений без ручного вмешательства. Подключая AACFlow к Amazon SQS, вы можете создавать агентов, которые публикуют сообщения в очередях в рамках ваших рабочих процессов — все без необходимости управления инфраструктурой очередей или подключениями.
Инструкции по использованию
Интегрируйте Amazon SQS в рабочий процесс. Может отправлять сообщения в очереди SQS.
Инструменты
sqs_send
Отправить сообщение в очередь Amazon SQS
Входные параметры
| Параметр | Тип | Обязательный | Описание |
|---|---|---|---|
region | string | Да | Регион AWS (например, us-east-1) |
accessKeyId | string | Да | Идентификатор ключа доступа AWS |
secretAccessKey | string | Да | Секретный ключ доступа AWS |
queueUrl | string | Да | URL очереди SQS (например, https://sqs.us-east-1.amazonaws.com/123456789012/my-queue) |
data | object | Да | Тело сообщения для отправки в виде объекта JSON (например, { "action": "process", "payload": { "data": "example" } }) |
messageGroupId | string | Нет | Идентификатор группы сообщений для очередей FIFO (например, "order-processing-group") |
messageDeduplicationId | string | Нет | Идентификатор дедупликации сообщений для очередей FIFO (например, "order-12345-v1") |
Выходные данные
| Параметр | Тип | Описание |
|---|---|---|
message | string | Сообщение о статусе операции |
id | string | Идентификатор сообщения |