AWS SQS队列无法触发Matillion作业问题求助

一、先检查Matillion SQS触发器的核心配置 #

• 确认触发器处于启用状态：进入Matillion项目的触发器管理页，找到关联目标SQS队列的触发器，查看状态是否为Active。连接测试成功不代表触发器已开启，这是最容易忽略的点。
• 核对消息解析与变量映射：
  • Lambda发送到SQS的消息大概率是JSON结构（比如{"file_name": "new_data.csv"}），你需要在Matillion触发器的“Message Processing”里配置正确的JSON路径，把文件名提取出来并映射到file_to_load环境变量。如果路径写错，变量会为空，作业要么不触发要么执行失败。
  • 检查是否设置了不必要的消息过滤规则，导致符合条件的消息被拦截。

二、验证SQS消息的实际格式 #

• 到AWS SQS控制台，手动查看队列里的一条消息内容，确认文件名所在的字段和层级。比如如果Lambda转发的是SNS的原始消息，结构可能是{"Message": "{\"s3_object_key\": \"target_bucket/xxx.csv\"}"}，这种情况下需要嵌套解析，先取$.Message，再解析里面的JSON提取文件名。
• 如果消息是纯文本（直接就是文件名字符串），要在Matillion触发器里选择Plain Text解析模式，将整个消息内容赋值给file_to_load。

三、确认作业与触发器的绑定逻辑 #

• 检查触发器关联的是否是目标作业，并且环境变量映射正确：在触发器配置的“Job Configuration”里，确认file_to_load变量确实绑定了从消息中提取的文件名。可以查看Matillion的触发器日志，验证变量是否被正确注入。
• 排查作业本身的启动限制：有些作业可能设置了前置条件（比如仅当file_to_load非空时才执行），如果变量没正确赋值，作业会被跳过。

四、权限与日志排查 #

• 检查Matillion所用IAM角色的权限：确保该角色拥有sqs:ReceiveMessage、sqs:DeleteMessage、sqs:GetQueueAttributes这几个核心权限。连接测试只验证了基础连接权限，没有这些操作权限的话，Matillion无法读取和处理SQS消息。
• 查看Matillion的触发器日志：在Matillion的「Logs」->「Trigger Logs」里找报错信息——比如消息解析失败、权限不足、作业执行超时等，这些日志能直接定位问题根源。
• 核对SQS队列的可见性超时：如果超时设置过短，Matillion可能还没处理完消息就被重新放回队列，但如果连读取记录都没有，大概率是权限问题。

内容的提问来源于stack exchange，提问作者brenda