aboutsummaryrefslogtreecommitdiffstats
path: root/python_moonclient/python_moonclient/core/json_import.py
blob: a724476b869683da4457a58891ecaaf9615baf3c (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
import logging
import requests
import copy
from python_moonclient.core import config


logger = logging.getLogger("moonclient.core.import_json")

URL = None
HEADERS = None

def init(consul_host, consul_port):
    conf_data = config.get_config_data(consul_host, consul_port)
    global URL, HEADERS
    URL = "http://{}:{}".format(
        conf_data['manager_host'],
        conf_data['manager_port'])
    URL = URL + "{}"
    HEADERS = {"content-type": "application/json"}


def import_json(file_name):
    files = {'file': open(file_name, 'rb')}
    req = requests.post(URL.format("/import"), files=files)
    result = req.json()
    if isinstance(result,dict) and "message" in result:
        req.reason = result["message"]
    req.raise_for_status()
    return result