Update

1.SQL导出工具完成
2.One-Click工具测试完毕

Author: egoleecode

Cli-Tools/one_click_tool.py

@@ -3,6 +3,7 @@
 import json
 import os
 import sys
+import time
 import shutil
 import random
 import requests
@@ -16,7 +17,7 @@ def get_config(config_path):
     else:
         print("Config文件不存在！请检查文件路径或使用其他模式")
         exit()
-    return config["mode"],config["file_path"],config["deal_duration"],config["if_gc"],config["minerid"],config["deal_times"],config["max_budget"],config["config_path"],config["encrypt_mode"],config["encrypt_key"]
+    return config["mode"],config["file_path"],config["deal_duration"],config["if_gc"],config["minerid"],config["deal_times"],config["max_budget"],config["config_path"],config["encrypt_mode"],config["encrypt_key"],config["cid_saving_path"]
 
 def get_opt():
     #在这里设定参数默认值
@@ -30,6 +31,7 @@ def get_opt():
     config_path = None
     encrypt_mode = None
     encrypt_key = "VshareCloud"
+    cid_saving_path = None
     #===============#
     args = sys.argv
     del args[0]
@@ -57,12 +59,14 @@ def get_opt():
             encrypt_mode = str(opt_content)
         elif opt_name in ("--encryptkey","-k"):
             encrypt_key = str(opt_content)
+        elif opt_name in ("--cid_saving_path","-o"):
+            cid_saving_path = str(opt_content)
         else :
             pass
     if config_path != None:
         return get_config(config_path)
     else:
-        return mode,file_path,deal_duration,if_gc,minerid,deal_times,max_budget,config_path,encrypt_mode,encrypt_key
+        return mode,file_path,deal_duration,if_gc,minerid,deal_times,max_budget,config_path,encrypt_mode,encrypt_key,cid_saving_path
 
 
 def get_cid(file_path,encrypt_mode,encrypt_key):
@@ -130,6 +134,15 @@ def get_vshare_nodeid():
     print("已选取到节点：%s" % minerid)
     return minerid
 
+def backup_cid(cid,cid_saving_path):
+    if cid_saving_path != None:
+        f = open("%s/vshare_cids.md" % cid_saving_path,'a')
+        f.write(str(cid)+ "|" + str(int(time.time())))
+        f.write('\n')
+    else:
+        pass
+    pass
+
 def ipfs_gc(cid):
     print("开始垃圾清理")
     subprocess.run("ipfs pin rm %s" % cid, shell=True)
@@ -148,11 +161,13 @@ def ipfs_gc(cid):
 config_path = opt[7]
 # encrypt_mode = opt[8]
 # encrypt_key = opt[9]
+cid_saving_path = opt[10]
 if mode == "1":
     minerid = get_vshare_nodeid()
     cmd = "expect /opt/vsharecloud-tools/scripts/single_deal.sh %s %s %s" % (cid, deal_duration, minerid)
     subprocess.run(cmd, shell=True)
     print("交易已发起，请通过命令 lotus client list-deals 查询交易状态")
+    backup_cid(cid,cid_saving_path)
     if if_gc == "y":
         ipfs_gc(cid)
     else:
@@ -162,6 +177,7 @@ def ipfs_gc(cid):
     cmd = "expect /opt/vsharecloud-tools/scripts/single_deal.sh %s %s %s" % (cid, deal_duration, minerid)
     subprocess.run(cmd, shell=True)
     print("交易已发起，请通过命令 lotus client list-deals 查询交易状态")
+    backup_cid(cid,cid_saving_path)
     if if_gc == "y":
         ipfs_gc(cid)
     else:
@@ -171,6 +187,7 @@ def ipfs_gc(cid):
     cmd = "expect /opt/vsharecloud-tools/scripts/global_deal.sh %s %s %s %s" % (cid, deal_duration, max_budget, deal_times)
     subprocess.run(cmd, shell=True)
     print("交易已发起，请通过命令 lotus client list-deals 查询交易状态")
+    backup_cid(cid,cid_saving_path)
     if if_gc == "y":
         ipfs_gc(cid)
     else:

Cli-Tools/scripts/mysql-backup/sql_backup_example.json

@@ -0,0 +1,7 @@
+{
+    "host": "127.0.0.1",
+    "port": 3306,
+    "db": "dbname",
+    "username": "root",
+    "password": "password"
+}

Cli-Tools/scripts/mysql-backup/sql_backup_tool.py

@@ -0,0 +1,72 @@
+# -*- coding: utf-8 -*-
+import os,time,MySQLdb,json,sys,subprocess
+
+def get_opt():
+    #在这里设定参数默认值
+    config_path = None
+    packup_path = None
+    #===============#
+    args = sys.argv
+    del args[0]
+    for arg in args:
+        arg = arg.split("=")
+        opt_name = arg[0]
+        opt_content = arg[1]
+        if opt_name in ("--config"):
+            config_path = str(opt_content)
+        elif opt_name in ("--packup-path"):
+            packup_path = str(opt_content)
+        else :
+            pass
+    return config_path,packup_path
+
+def get_db_config(config_path):
+    if os.path.isfile(config_path):
+        f = open(config_path)
+        sqlpwd = json.load(f)
+        f.close()
+    else:
+        print("SQL Config 文件不存在！")
+        exit()
+    return sqlpwd
+
+def getDatabaseNames(sql_config):
+    db = MySQLdb.connect(host=sql_config['host'], port=sql_config['port'], user=sql_config['username'], passwd=sql_config['password'], db=sql_config['db'], charset='utf8')
+    cursor = db.cursor()
+    cursor.execute('show databases;')
+    dbs = cursor.fetchall()
+    db.close()
+    return dbs
+
+def mkdir(path):
+    path = path.strip()
+    path = path.rstrip("\\")
+    isExists = os.path.exists(path)
+    if not isExists:
+        os.makedirs(path)
+        return True
+    else:
+        return False
+
+#Main
+config_path = get_opt()[0]
+packup_path = get_opt()[1]
+sql_config = get_db_config(config_path)
+timestr = time.strftime("%Y%m%d-%H%M%S",time.localtime(time.time()))
+if os.path.exists(packup_path) == False:
+    os.makedirs(packup_path)
+else:
+    pass
+dbs = getDatabaseNames(sql_config)
+print(dbs)
+for db in dbs:
+    try:
+        dbname = db[0]
+        if dbname=="mysql" or dbname=="performance_schema" or dbname=="information_schema" or dbname=="sys":
+            pass
+        else:
+            cmd = "mysqldump -u%s -p%s %s > %s/%s.sql" % (sql_config['username'], sql_config['password'], dbname, packup_path, (sql_config['db']+"_"+timestr))
+            print(cmd)
+            subprocess.run(cmd,shell=True)
+    except Exception as error:
+        print(error)