如何使用python boto3将消息发送到本地SQS队列？

Question

我试图使用https://github.com/roribio/alpine-sqs容器

我能够运行docker容器，并使用终端将消息发送到队列。

我用来将消息发送到SQS队列容器的命令如下

aws --endpoint-url http://localhost:9324 sqs send-message --queue-url http://localhost:9324/queue/default --message-body "Hello, queue!"

我能够接收到消息，并且可以在浏览器中的dashboad中看到它，网址为localhost:9235。

但是当我试图在python中使用boto3发送消息时，它抛出了一个错误。

回溯（最后一次调用）：文件“/home/infomagnus/PycharmProjects/infomagnus/workload/app/workload/services/queue_services.py”，第13行，在“关于当前纽约时报小说畅销书的信息”文件“/home/infomagnus/envs/DSDPenv/lib/python3.7/site packages/botocore/client.py”，第357行，在_api_call return self中_make_api_call（operation_name，kwargs）File“/home/infomagnus/envs/DSDPenv/lib/python3.7/site packages/botocore/client.py”，第661行，位于make_api_call raiser error_class（解析响应，operation_name）botocore中。例外。ClientError:调用SendMessage操作时发生错误（InvalidClientTokenId）：请求中包含的安全令牌无效

不确定为什么即使在使用aws configure设置按键后也会出现错误。

我运行的所有东西都在我的本地。

这是我的代码：

import boto3
sqs = boto3.client('sqs', aws_access_key_id=None, aws_secret_access_key=None)
queue_url = 'http://localhost:9324/queue/default'
resp = sqs.send_message(
    QueueUrl=queue_url,
    MessageBody=(
        'Sample message for Queue.'
    )
)
print(resp['MessageId'])

Answer 1

您忘记传递endpoint\u url。

sqs = boto3.client('sqs', aws_access_key_id=None, aws_secret_access_key=None, endpoint_url='http://localhost:9324')