如何使用Jenkinsfile获取AWS SQS消息？求示例代码

嗨，我来帮你搞定这个问题！当你通过Jenkins的SQS插件触发流水线后，插件其实会自动把SQS消息的相关内容注入到流水线的环境变量里，你直接读取这些变量就能拿到消息内容了。下面给你一个完整的Jenkinsfile示例，还有一些关键细节说明：

首先确保你已经完成了这些配置：

• 在Jenkins中安装并配置好AWS SQS插件，包括正确的AWS凭证（要有SQS的读写权限）、队列URL，并且已经给你的流水线设置了SQS触发器。

pipeline {
    agent any

    // 这里替换成你的队列信息和AWS凭证ID
    triggers {
        sqs(queue: 'https://sqs.us-east-1.amazonaws.com/123456789012/your-target-queue', 
            awsCredentials: 'your-aws-credential-id',
            region: 'us-east-1')
    }

    stages {
        stage('获取并处理SQS消息') {
            steps {
                script {
                    // 从环境变量中读取SQS消息核心内容
                    def messageBody = env.SQS_MESSAGE_BODY
                    def messageId = env.SQS_MESSAGE_ID
                    def receiptHandle = env.SQS_MESSAGE_RECEIPT_HANDLE
                    def queueUrl = env.SQS_QUEUE_URL

                    // 检查是否成功获取到消息
                    if (messageBody) {
                        echo "✅ 收到SQS消息，ID: ${messageId}"
                        echo "📝 原始消息内容:"
                        echo messageBody

                        // 示例：如果消息是JSON格式，解析成Groovy对象方便处理
                        try {
                            def parsedMsg = readJSON text: messageBody
                            echo "🔍 解析后的消息结构:"
                            echo parsedMsg
                            // 这里可以添加你的业务处理逻辑，比如根据消息内容触发不同操作
                        } catch (Exception e) {
                            echo "⚠️ 消息不是有效JSON格式，跳过解析"
                        }
                    } else {
                        echo "❌ 未获取到SQS消息，请检查触发器配置"
                    }
                }
            }
        }
    }

    post {
        success {
            echo "🎉 消息处理完成"
            // 可选：如果插件没有自动删除消息，手动调用AWS CLI删除
            // 注意：确保Jenkins节点已安装AWS CLI并配置好权限
            sh """
                aws sqs delete-message \
                    --queue-url ${queueUrl} \
                    --receipt-handle ${receiptHandle} \
                    --region us-east-1
            """
        }
        failure {
            echo "❌ 消息处理失败，根据SQS可见性超时设置，消息会重新回到队列"
        }
    }
}

• 环境变量说明：SQS插件会自动注入这些常用变量：
  • SQS_MESSAGE_BODY：消息的原始内容（字符串格式）
  • SQS_MESSAGE_ID：消息的唯一标识ID
  • SQS_MESSAGE_RECEIPT_HANDLE：用于删除消息的句柄
  • SQS_QUEUE_URL：触发流水线的SQS队列URL
• 消息删除逻辑：默认情况下，插件会在流水线成功结束后自动删除消息；如果需要自定义删除条件（比如只有处理完特定步骤才删除），可以用上面示例中的AWS CLI命令手动操作。
• 权限注意：确保你的AWS凭证拥有sqs:ReceiveMessage、sqs:DeleteMessage等权限，否则会出现权限错误。
• 消息解析：如果消息是JSON格式，Jenkins内置的readJSON步骤可以快速解析成可操作的对象，非常方便后续业务逻辑处理。

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