У меня есть 3 AWS SQS FIFO для масштабируемости.Каждая из них запускает сложную задачу, которую я собираюсь назвать create
, createWithPriority
и update
только для простоты.
Мне нужен трансверсал MessageGroupID
(я думаю, что это путь, но я открыт для предложений здесь), поэтому я могу получать сообщения в порядке из трех очередей , учитывая, что я не могу сделать обновление для чего-то, что еще не было создано.
Я видел несколько статей о комплексном управлении SQS , но я не смог найти никого о MessageGroupID
совместном использовании ... или о том, что можно сделать для проверки по группе , чтоМне нужно.
Я пытаюсь использовать (если есть) способ AWS сделать это.Я подумаю, что есть хорошая практика, которую я здесь упускаю.
В противном случае у меня будет обходной путь для лямбды-потребителей, но я должен попробовать.