У меня есть маршрут колбы, который должен генерировать события сервера для браузера.Основное, что делает функция: 1. загрузить файл csv 2. для каждой строки файла csv 3. сохранить имя пользователя и адрес электронной почты в базе данных sql (используя sqlalchemy) 4. счетчик обновлений (для статуса выполнения) 5. отправить событие вбраузер
Дело в том, что эта функция хорошо работает, когда я нахожусь в режиме разработки (с использованием встроенного в колбу сервера), но в производственном режиме (с использованием NginX и gunicorn) функция останавливается через несколько секунд, так чтосчетчик никогда не достигает 100, это приводит к тому, что браузер снова вызывает функцию, и этот цикл никогда не заканчивается, потому что событие никогда не получает оператор close.Итак, главный вопрос: почему это работает в разработке, а не в производстве?Вот код mi:
# Update or construct database if a csv file was submitted
@app.route("/constructDatabase/<string:filename>", methods=["GET","POST"])
def constructDatabase(filename):
# context manager to open csv file
csvFile = open(os.path.join(os.getcwd(), filename), newline='')
# get lines count of csv file
totalLines = len(csvFile.readlines())
# reset reader pointer
csvFile.seek(0)
# current percent status
current_status = 0
def generate(file, counter):
# unpack and iterate over the csv file to get all the names and emails
for Company,Address,City,State,Zip,County,Phone,Website,Contact,Title,Direct_Phone,Email,Sales,Employees,SIC_Code,Industry in csv.reader(file, delimiter=','):
yield ':keep connection alive\n\n'
counter += 1
# if a user has not contact name or email then not useful
if Email == None or Email == '':
yield f'id: {counter}\nevent: message\ndata: {round(counter / totalLines * 100, 1)}\n\n'
continue
if Contact == None or Contact == '':
yield f'id: {counter}\nevent: message\ndata: {round(counter / totalLines * 100, 1)}\n\n'
continue
# Create user as instance of User class
user = Users(company=Company, address=Address, city=City, state=State,
zip=Zip, country=County, phone=Phone, website=Website, contact=Contact,
title=Title, direct_phone = Direct_Phone, email=Email, sales=Sales,
employees=Employees, sic_code=SIC_Code, industry=Industry)
# Add user to database
db.session.add(user)
# get current percent status of building database
yield f'id: {counter}\nevent: message\ndata: {round(counter / totalLines * 100, 1)}\n\n'
# Save changes in database
db.session.commit()
print("SAVING DATABASE .......")
# close file
file.close()
return Response(generate(csvFile, current_status), mimetype='text/event-stream')
Код Java-скрипта сейчас: javascript
// create Event source connection with the server to listen for incoming msg
var source = new EventSource(`/constructDatabase/${filename}`);
// if new msg was received
source.onmessage = function(msg) {
// update progress bar
$('.progress-bar').css('width', msg.data+'%').attr('aria-valuenow', msg.data);
// if is 100 percent close connection to the server
if (msg.data == 100) {
source.close();
// Hide label
$('.prog-bar-label').addClass('d-none');
// Hide CSV progress bar
$('.csvProgressBar').addClass('d-none');
// reset progress bar
$('.csvProgressBar').find('.progress-bar').css('width', 0+'%').attr('aria-valuenow', 0);
}
};
source.onerror = function(error){
console.log(error.data);
};