Как я могу это диагностировать? Раньше это происходило мгновенно, и я не уверен, почему это стало занимать больше времени, поскольку 3 недели назад. В производственном сценарии используется многопроцессорность. Я создал модуль, содержащий несколько определений, и вызываю одно из этих определений в сценарии многопроцессорной обработки:
Код: Выделить всё
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()
Код: Выделить всё
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
Код: Выделить всё
import numpy as np, time
T1 = time.time()
data = np.load(dataPath + newEntry["fileName"] + ".npy")
T2 = time.time()
print(T2-T1)
Подробнее здесь: https://stackoverflow.com/questions/797 ... in-another
Мобильная версия