Simple ElasticSearch-DSL Python Example

gistfile1.py

if __name__ == "__main__":
  c = Elasticsearch("http://192.168.2.218:9200")
  f = open(sys.argv[1])

  for line in f:
    # Convert public_hostname to IPs because hostname lookups are failing in ES for some reason
    if line.find("ec2") > -1:
      host = socket.gethostbyname(line.rstrip().lstrip())
    else: 
      host = line.rstrip().lstrip()
    s = Search(using=c, index="_all").filter("term", ec2_public_ipv4=host)
    r = s.execute()
    for h in r.hits:
      print line.rstrip(),host, h['instanceid'], h['facter']['ec2_instance_type'],h['facter']['ec2_placement_availability_zone'],h['os_packages']['tomcat7'],h['os_packages']['openjdk-6-jre-headless'],
      dump_webapps(h['webapps'])