Amazon Simple Queue Service (Amazon SQS) offre une file d'attente hébergée fiable et hautement évolutive pour le stockage des messages lors de leurs déplacements entre les ordinateurs.

Plus à propos amazon-sqs...

J'ai beaucoup de mal à essayer de savoir comment configurer correctement sqs dans boto3 pour pouvoir envoyer des messages à ma file sqs. Il semble qu'il y ait une certaine confusion autour de boto3 et de l'héritage .......
17 mars 2021 à 03:13
Nouveau sur Terraform :: Nous avons un module de communauté pour SQS que la plupart des développeurs utilisent pour lancer une file d'attente SQS et il est livré avec quelques (4) balises (la communauté n'a pas de module de balises réutilisable pour le moment). Pour mon projet, j'ai besoin de balis....
J'ai deux files d'attente lambdas et une SQS entre les deux. Le premier objectif de lambda est de sélectionner les identifiants de produits de aurora MySQL et de les envoyer à SQS. Il existe plus de 7 millions d'identifiants de produits. Lorsque le premier lambda envoie ces identifiants de produi....
Pour clarifier, ce que j'essaie de faire est de déclencher une tâche Fargate quand il y a un élément dans une file d'attente spécifique. J'ai utilisé ce tutoriel < / a> pour arriver à peu près là où je suis. Cela a bien fonctionné, mais le problème que j'ai rencontré était que chaque téléchargem....
Je souhaite utiliser API Gateway pour envoyer un message à SQS qui doit ensuite déclencher Lambda. Une fois les calculs terminés dans Lambda, je dois renvoyer les résultats à API Gateway. En d'autres termes, .......
J'essaie de configurer la politique SQS pour qu'une file d'attente autorise tous les principes d'un compte à envoyer des messages à cette file d'attente, selon la documentation ici: { "Version": "2012-10-17", "Id": "sqspolicy", "Statement": [ { "Sid": "Sqs policy1", ....
23 févr. 2021 à 13:40
Comme SQS est la file d'attente de distribution, réplique-t-il les messages dans la même région ou dans une région différente? Examen de l'architecture sur AWS docs, il montre le message en cours de réplication, mais est-il répliqué dans la même région ou dans différentes régions? Cas d'utilisati....
Je prévois d'utiliser AWS SQS pour recevoir des messages du serveur, puis demander instantanément à Kubernetes Load Balancer de les consommer et de transmettre chaque message à l'un des pods. Ma plus grande préoccupation est de savoir de quelle manière Load Balancer peut être déclenché par AWS S....
J'ai configuré une file d'attente SQS où les chemins S3 sont poussés chaque fois qu'il y a un téléchargement de fichier. J'ai également configuré un Lambda avec un déclencheur SQS et une taille de lot de 1. Dans mon scénario, je dois traiter n .......
12 févr. 2021 à 20:22
Il y a environ 20K messages dans le backlog pour la file d'attente fifo. Lambda est le consommateur de la file d'attente fifo. Une source pousse les messages vers la file d'attente FIFO avec l'ID de groupe - Group1. Il y avait une exception réessayable lancée à partir du code lambda, le lot entier....
10 févr. 2021 à 16:41
Scénario: Je souhaite disposer d'une route de passerelle API AWS qui transmet le corps de la demande d'appel HTTP POST au service AWS SQS. J'ai réussi cela en utilisant la nouvelle interface de console AWS pour la passerelle API et Amazon Simple Queue Service comme cible d'intégration. Maintenant, ....
J'essaye d'utiliser MassTransit SQS pour publier un message. Voici mon code de configuration: public static void UseMassTransit(this IServiceCollection services, MassTransitConfiguration massTransitConfiguration) { services.AddMassTransit(x => { x.AddConsumer<Cus....
9 févr. 2021 à 20:44
J'utilise MassTransit SQS. J'ai découvert que lorsque publiant un message, ce problème se produisait: L'utilisateur n'est pas autorisé à effectuer: SNS: CreateTopic sur la ressource J'ai donc besoin de droits pour créer des sujets. Je l'ai résolu en demandant à l'administrateur d'étendre les droits....
8 févr. 2021 à 23:23
J'utilise MassTransit dans une application Web principale .NET (API Web) pour utiliser SQS. Cela fonctionnait bien pour publier des messages. Mais après avoir essayé d'ajouter un consommateur, j'ai rencontré un problème. Voici mon code public static void UseMassTransit(this IServiceCollection ....
8 févr. 2021 à 21:58
Existe-t-il un moyen d'arrêter dynamiquement de consommer des événements lors de l'utilisation du mappage de source d'événements intégré à aws lambda? Dans l'exemple de diagramme, je me fierais au bilan de santé du Big Service pour prendre cette décision. Jusqu'à présent, je sais que si Big Service....
Le cas d'utilisation est que des milliers de fichiers de très petite taille sont téléchargés vers s3 chaque minute et que tous les objets entrants doivent être traités et stockés dans un compartiment séparé à l'aide de lambda. Mais l'utilisation de s3-object-create comme déclencheur entraînera de n....
J'essaie de créer une file d'attente SQS et sa politique d'accès associée à l'aide de cloudformation. J'ai essayé quelques itérations mais cela continue de me donner cette erreur: Valeur de la propriété Les files d'attente doivent être de type Liste de chaînes Ci-dessous mon modèle. Quelqu'un peut....
J'ai la méthode suivante dans ma classe Java: public class AwsHelper { private AmazonSQS sqs; private void sendMessageToQueue(String message){ sqs = AmazonSQSClientBuilder.defaultClient(); SendMessageRequest sendMessageRequest = new SendMessageRequest(); sendMessageRe....
Je me demande ce qui se passerait s'il y avait un sujet SNS contenant des messages, mais pendant un certain temps, il n'y a pas de file d'attente SQS. Disons qu'il y avait un conteneur qui était normalement abonné à la rubrique SNS pour gérer ces messages, mais il s'est écrasé et brûlé et a passé 1....
25 janv. 2021 à 14:45
J'utilise les 3 services suivants: Amazon S3 , Amazon SQS et AWS Lambda . La même configuration est créée pour le traitement des fichiers CSV et EXCEL (la fonction lambda qui traite les fichiers EXCEL les convertit simplement en fichiers CSV et les retélécharge vers S3 afin que l'autre fonction ....
Je suis confronté à un problème étrange dans SQS. Permettez-moi de simplifier mon cas d'utilisation, j'ai 7 messages dans la file d'attente FIFO et mon application autonome devrait continuer à interroger les messages dans la même séquence pour mon business case à l'infini. Par exemple, mon applica....
22 janv. 2021 à 11:39
Quelle est la meilleure façon d'interroger les messages d'Amazon Web Services SQS? Je veux traiter les messages dès qu'ils sont dans la file d'attente et je ne veux pas vraiment interroger toutes les secondes à moins que ce ne soit la seule option? setInterval(run(), 1000); J'obtiens l'erreur const....
16 janv. 2021 à 17:54
Dois-je toujours spécifier endpoint_url lors de la création du client boto3? Pourquoi ne puis-je pas spécifier QueueUrl comme argument de méthode? # boto3 == 1.16.51 importer boto3 client = boto3.client ('sqs') messages = client ........
11 janv. 2021 à 11:36
Je tire des données d'une API par lots et je les envoie à une file d'attente SQS. Là où je rencontre un problème, c'est le traitement du message afin d'envoyer les données à DynamoDB. Il est censé y en avoir 147689 .......
Je crée une application qui ne devrait stocker que certaines configurations. J'utilise AWS AppConfig comme magasin de configuration. Je souhaite pouvoir mettre à jour ces données de configuration via le code. Donc quand .......