add dynamic-version-awareness and 1.3.2 support to elasticsearch

Jeff Kramer · Jeff Kramer · commit 1eba68cd37c3 · 2015-07-17T10:08:14.000-05:00
diff --git a/elasticsearch/python_modules/elasticsearch.py b/elasticsearch/python_modules/elasticsearch.py
@@ -187,12 +187,17 @@ def metric_init(params):
 
     host = params.get('host', 'http://localhost:9200/')
 
-    version = params.get('version', '1.2')
-    
+    result = json.load(urllib.urlopen(host))
+
+    host_version = result.get('version',{}).get('number') or "1.2"
+    version = params.get('version', host_version)
+
     m = re.match('(?P<major>\d+)\.(?P<minor>(\d+(\.\d+)*))', version)
-     
+
     if m and m.group('major') == '0':
         url_cluster = '{0}_cluster/nodes/_local/stats?all=true'.format(host)
+    elif m and m.group('major') == '1' and m.group('minor') == '3.2':
+        url_cluster = '{0}_nodes/_local/stats'.format(host)
     else:
         url_cluster = '{0}_cluster/state/nodes'.format(host)
 
