python - 如何配置Elasticsearch从Amazon SQS提取消息

Question

在当前情况下，我在Ubuntu 14.04机器上具有ElasticSearch，并且在队列中保存一些“.json”消息的亚马逊SQS队列。我想通过ES从亚马逊SQS中提取消息，以便它可以使用.json消息对其进行索引。

我应该寻找什么，应该如何进行？我正在寻找python boto代码行中的某些内容。

注意:我对此不感兴趣使用logstash

Answer 1

Amazon SQS提供了一个用于接收消息的API:http://docs.aws.amazon.com/AWSSimpleQueueService/latest/SQSGettingStartedGuide/ReceiveMessage.html

ElasticSearch提供了一个API来索引消息:
https://www.elastic.co/guide/en/elasticsearch/client/java-api/current/index-doc.html

我不确定ES是否可以自动从SQS接收消息，但是一个可行的解决方案是SQS和ES之间的简单代理以接收和编制索引。