ops/ops_interface
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

数数虚拟维度表导入脚本

Browse Source
This commit is contained in:
pengtao 2019-10-15 14:29:47 +08:00
parent fa68e5ff77
commit 657578c3ff
1 changed files with 16 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
ops/ss_virtual_create.py
View File

@ -4,7 +4,7 @@ import requests
import sys import sys
from urllib.parse import unquote, quote, urlencode from urllib.parse import unquote, quote, urlencode
import pdb import pdb
import subprocess
def my_quote(data): def my_quote(data):
if isinstance(data, dict): if isinstance(data, dict):
@ -15,11 +15,11 @@ def my_quote(data):
class SS_Virtual_command: class SS_Virtual_command:
def __init__(self): def __init__(self):
self.ss_virtual_url = "https://10.10.3.17:8992/v1/ta/meta/prop/virtual/dict/create" self.ss_virtual_url = "http://10.10.3.14:8993/v1/ta/meta/prop/virtual/dict/create"
self.method = "post" self.method = "post"
def upload(self, filename): def upload_gameid(self, filename):
projectId = int(19) projectId = int(19)
createParam = {"commonHeader": {"projectId": 19}, createParam = {"commonHeader": {"projectId": 19},
@ -28,12 +28,23 @@ class SS_Virtual_command:
{"property": {"columnName": "gameid_china", "columnDesc": "china映射", "selectType": "string"}}]} {"property": {"columnName": "gameid_china", "columnDesc": "china映射", "selectType": "string"}}]}
loginName = "root" loginName = "root"
password = "kingsome2016" password = "kingsome2016"
pdb.set_trace()
body = {"projectId": projectId, "createParam": createParam, "loginName": loginName, "password": password} body = {"projectId": projectId, "createParam": createParam, "loginName": loginName, "password": password}
quote_body = my_quote(body) quote_body = my_quote(body)
cmd = f"curl --header 'Accept: application/json' --form 'file=@{filename}' {self.ss_virtual_url}?{quote_body}" cmd = f"curl --header 'Accept: application/json' --form 'file=@{filename}' {self.ss_virtual_url}?{quote_body}"
print(cmd) print(cmd)
cmdref = subprocess.Popen(cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE, shell=True)
output, error_info = cmdref.communicate()
if cmdref.returncode != 0:
if isinstance(error_info, list) or isinstance(error_info, tuple):
error_info = error_info[0]
msg = "RUN %s ERROR,error info: %s" % (cmd, error_info)
print(f"{msg},error info={error_info}")
return False
else:
print("Run Success")
return True
# r = requests.post(url=self.ss_virtual_url, header="Accept: application/json", files=filename, data=quote_body) # r = requests.post(url=self.ss_virtual_url, header="Accept: application/json", files=filename, data=quote_body)
# if r.status_code == requests.codes.ok: # if r.status_code == requests.codes.ok:
# print(f"upload success,return={r.content}") # print(f"upload success,return={r.content}")
@ -49,7 +60,7 @@ def main():
filename = sys.argv[1] filename = sys.argv[1]
ss = SS_Virtual_command() ss = SS_Virtual_command()
ss.upload(filename) ss.upload_gameid(filename)
if __name__ == "__main__": if __name__ == "__main__":