Bläddra i källkod

fix thread problem

master
Jeong Geol Kim 4 år sedan
förälder
incheckning
de4888a238
1 ändrade filer med 36 tillägg och 0 borttagningar
  1. 36
    0
      auto_extract.py

+ 36
- 0
auto_extract.py Visa fil

@@ -42,6 +42,42 @@ def main():
42 42
                     r_time = time.ctime(time.time())
43 43
                     f.write('exectue is successfully ends at ' + str(r_time) + '\n')
44 44
                     f.close()
45
+
46
+                    #NOTE: Starting global coordinate
47
+                    f = open(file, 'at')
48
+                    r_time = time.ctime(time.time())
49
+                    f.write('global coordinate successfully starts at ' + str(r_time) + '\n')
50
+                    f.close()
51
+                    #FIXME: change coordinate_g.py when IMU sensor works
52
+                    os.system('docker run --rm --name coordinate --gpus '"device=1"' -v /dev:/dev -v /home/mc365/sources:/sources -v /hdd:/hdd ellishuntingmoon/mailsys:0.4 python3 /sources/coordinate_g.py ' + id + '/ >> /dev/null')
53
+                    f = open(file, 'at')
54
+                    r_time = time.ctime(time.time())
55
+                    f.write('global coordinate successfully ends at ' + str(r_time) + '\n')
56
+                    f.close()
57
+
58
+
59
+                    #NOTE:
60
+                    f = open(file, 'at')
61
+                    r_time = time.ctime(time.time())
62
+                    f.write('kpi successfully starts at ' + str(r_time) + '\n')
63
+                    f.close()
64
+                    #FIXME: change coordinate_g.py when IMU sensor works and get generic optimizer for DBSCAN
65
+                    os.system('docker run --rm --name kpi --gpus '"device=1"' -v /dev:/dev -v /home/mc365/sources:/sources -v /hdd:/hdd ellishuntingmoon/mailsys:0.4 python3 /sources/kpi.py ' + id + '/ >> /dev/null')
66
+                    f = open(file, 'at')
67
+                    r_time = time.ctime(time.time())
68
+                    f.write('kpi successfully ends at ' + str(r_time) + '\n')
69
+                    f.close()
70
+
71
+                    transport = paramiko.Transport(('365mc.iptime.org', 63122))
72
+                    transport.connect(username='mc365', password='tkadbrdhMC1!')
73
+                    sftp = paramiko.SFTPClient.from_transport(transport)
74
+                    #FIXME: send file recursively
75
+                    for file in file_list:
76
+                        sftp.put(file,'/data/'+str(file[5:]))
77
+                    sftp.close()
78
+                    transport.close()      
79
+                    os.system('rm -rf '+id)     
80
+
45 81
                 else:
46 82
                     pass
47 83
 

Laddar…
Avbryt
Spara