基于消息属性从Amazon SQS向SQL数据库发送消息
我的任务用例：现在的用例是，我在一个表单中填写名字、姓氏等细节，然后单击Submit按钮，数据直接进入Amazon SQS，然后定义了一个包含按钮的侦听器，单击该按钮，数据从侦听器进入MSSQL数据库。
场景（当前）：现在，所有属于不同消息属性的消息都将被发送。
要求：我要发送属于特定消息属性的特定消息。例如：假设A类、B类和C类是三个不同的消息属性，A类包含一个消息，B类包含两个消息，C类包含四个消息，我想要的只是发送B类属性的消息，而不是A类和C类属性的消息。
我想知道是否可以根据Amazon SQS的消息属性只发送选定的/特定的消息到SQL db？
任何帮助都将不胜感激。提前道谢。
共有1个答案
无法根据消息属性有选择地传递SQS消息。标准做法是每一类使用者都有自己的队列，这样就不需要过滤，因为假设给定队列的所有使用者都能够处理队列中的所有消息。
如果您确实需要一个公共消息源，以便通过消息属性筛选其输出，那么建议的解决方案是将消息发布到SNS主题，然后根据SNS支持的消息属性筛选器将队列订阅到该主题。例如，这种配置将允许队列1捕获类型A、B和C的消息，同时允许队列2捕获类型C、D和E的消息。注意类型C上的重叠。在这种配置中，这类消息将被传递到两个队列。
请参见使用Amazon SNS过滤消息并发送扇出事件通知。
-
我有一个应用程序，它定期生成原始JSON消息数组。我能够使用avro-tools将其转换为Avro。我这样做是因为由于Kafka-Connect JDBC接收器的限制，我需要消息包含模式。我可以在记事本上打开这个文件，看到它包括模式和几行数据。 现在，我想将其发送到我的中央Kafka代理，然后使用Kafka Connect JDBC接收器将数据放入数据库。我很难理解我应该如何将这些Avro文件发送
-
我需要实现向带有属性的SQS发送消息。消息的正文上传良好，但我有问题的属性。消息属性需要具有属性名称、数据类型和值的关联数组。我有这样的错误： $Attributes数组应该是什么样子？
-
我一直试图通过按钮单击（mRescue）在我的数据库（Emergency_Contact）中发送自定义消息，当单击按钮时，它将检查在签入之后按下按钮的人的对于每个拥有作为他们的孩子的人，如果他们拥有作为他们的孩子，它会向他们发送消息，否则它会返回Toast消息。我试图运行我的代码，但它崩溃了，我不知道为什么。这是我的活动，执行此操作。 如何发送此消息？ 这是我的logcat
-
接口说明 轻推轻应用/订阅号支持发送文本、图片、文本卡片、图文、key-value、文件、待办等消息类型。本接口针对各种消息类型和发送的对象（单发、群发以及给部分人发送）进行了定义。 注：openid是用户关注某个轻应用/订阅号后生成的唯一id,单发和给部分人发送消息必须携带此参数，可以通过如下接口来获取： 根据qt_code获取用户基本信息 获取使用者列表 通过userId获取openid 消息
-
主动发送消息 use EasyWeChat\Kernel\Messages\TextCard; // 获取 Messenger 实例 $messenger = $app->messenger; // 准备消息 $message = new TextCard([ 'title' => '你的请假单审批通过', 'description' => '单号：1928373, ...
-
向已经创建连接凭据的设备发送消息数据。 请求方式： |4|2|3|message|\r 参数 message 发送的消息内容 返回值： "|4|2|3|1|\r" 发送成功 "|4|2|3|2|\r" 发送失败 Arduino样例： softSerial.print("|4|2|3|DFRobot|\r");