Wie kann ich das diagnostizieren? Früher funktionierte es sofort, und ich bin nicht sicher, warum es seit drei Wochen länger dauert. Das Produktionsskript verwendet Multiprocessing. Ich habe ein Modul erstellt, das mehrere Definitionen enthält, und rufe eine dieser Definitionen im Multiprocessing-Skript auf:
Code: Select all
from projectAI.projectAI import dataProcessor
.
.
.
initializations
.
.
.
processes = []
process1 = Process(target = dataProcessor,
args   = (genModelName, dataPath, DB, Max, Min),
daemon = True)
processes.append(process1)
for i in range(Count):
process = Process(target = appEstimator,
args   = (Data, str(i+1), city),
daemon = True)
processes.append(process)
for process in processes:
process.start()
for process in processes:
process.join()
Code: Select all
dataProcessor(genModelName, dataPath, DB, Max, Min):
while True:
# Check for a new entry in DB using queries
if newEntry:
data = np.load(dataPath + newEntry["fileName"] + ".npy")
# Further processing
Code: Select all
import numpy as np, time
T1 = time.time()
data = np.load(dataPath + newEntry["fileName"] + ".npy")
T2 = time.time()
print(T2-T1)
 Mobile version
 Mobile version