curl -XPUT 'localhost:9200/_snapshot/my_backup/snapshot_2?wait_for_completion=true&pretty' -H 'Content-Type: application/json' -d'
{
  "indices": "index_1,index_2",
  "ignore_unavailable": true,
  "include_global_state": false
}'

#!/usr/bin/python
# -*- coding: utf-8 -*-
import json
from collections import defaultdict
import urllib2
import requests
from random import randrange
from requests.auth import HTTPBasicAuth
import sys
import threading
reload(sys)
sys.setdefaultencoding("utf-8")

headers = {'Content-Type': 'application/json'}
data = {"type": "fs", "settings": {"location": "/home/gnsarchlab/backup"}}
tmpdict = defaultdict()
tmpdict = json.dumps(data)
method=""

def initialiseSnapshot():

    response=requests.put('http://localhost:9200/_snapshot/my_backup?pretty',headers=headers,data = tmpdict)
    print response
    if(response.status_code != None and response.status_code == 200):
        print "Snapshot Initiated"
        print response.status_code

    else:
        print "Error initialsing snapshot"
        print response.status_code


def validatingRepository():

    response=requests.get('http://localhost:9200/_snapshot/my_backup?pretty')
    print response

    if(response.status_code != None and response.status_code == 200):
        print "Repository Validated"
        print response.status_code

    else:
        print "Error validating repository"
        print response.status_code

def capturingSnapshot():

    print "Enter 0 for taking snapshot of all the indices."
    print "Enter 1 to give the name of the indice"
    indice = int(raw_input())
    if indice == 0:
        response=requests.put('http://localhost:9200/_snapshot/my_backup/snapshot_1?wait_for_completion=true&pretty')
        print response

        if(response.status_code != None and response.status_code == 200):
            print "Snapshot Captured"

        else:
            print "Error capturing snapshot"

    if indice == 1:
        indice_name = raw_input("Enter indice name: ")
        datadict = defaultdict()
        data1 = {"ignore_unavailable": "true", "include_global_state": "false"}
        data2 = defaultdict()
        data2['indices'] = indice_name
        print data2
        data1.append(data2)
        print data1
        datadict = json.dumps(data1)
        response1=requests.put('localhost:9200/_snapshot/my_backup/snapshot_2?wait_for_completion=true&pretty',data=datadict)
        print response

        if(response.status_code != None and response.status_code == 200):
            print "Snapshot Captured"

        else:
            print "Error capturing snapshot"


if __name__ == "__main__":

    if(len(sys.argv) < 2):
        print "Usage : python sdn.py [initialise|validate|capture|all]"
    elif(sys.argv[1] == "initialise"or sys.argv[1] == "is"):
        initialiseSnapshot()
    elif(sys.argv[1] == "validate" or sys.argv[1] == "vr"):
        validatingRepository()
    elif(sys.argv[1] == 'capture' or sys.argv[1] == "cs"):
        capturingSnapshot()
    elif(sys.argv[1] == 'all'):
        initialiseSnapshot()
        validatingRepository()
        capturingSnapshot()

if indice == 1:
    ...
    data1 = {"ignore_unavailable": "true", "include_global_state": "false"}
    data1.append(data2) # here

if indice == 1:
    ...
    data1 = {"ignore_unavailable": "true", "include_global_state": "false"}
    data1['datas'] = []
    data1['datas'].append(data2) # here