Я сегодня дома
Есть список значений, скрипт берёт их по очереди и на основе значения производит изменения в бд. Как сделать безопасный выход из скрипта в момент выполнения, что бы не получить неконсистентных данных в бд?
Andrey
Господа, а как правильно сделать? Параллелю выполнение функции, делаю for x in all_ips:
print(x)
temp = {}
my_thread = threading.Thread(target=descr, args=(x, ))
my_thread.start()
Andrey
в итоге, мне нужно получить словарь из значений, которые генерирует функция. В принципе, добавление значений в словаь можно даже не локать, как я понимаю. Однако. как мне добыть переменную с этим словарём вне функции, чтобы работать с ней дальше?
Dregaadan
Всем привет, подскажите пожалуйста, что я делаю не так.
Есть метод в REST апи, по его вызову я хочу вызвать асинхронную функцию и отправить ответ, что процесс запущен, по окончанию процесса слать ответ, что задание выполнено такие результаты (по факту async REST запрос)
Я делаю через asyncio, но ну получается распаралетить, функция исполняется в основном потоке.
Вот код:
REST метод, который принимает запрос
class PdfParser:
def on_post(self, req, resp):
"""Handles GET requests"""
try:
data = req.stream.read(req.content_length or 0)
json_raw = json.loads(data)
print("data: ", json_raw)
# print(body)
asyncio.run(send_response(json_raw['filename']))
response = {
"Status": "OK",
"Error": ""
}
resp.content_type = 'application/json'
resp.media = response
except Exception as error:
resp.status = falcon.HTTP_500
response = {
"Status": "Error",
"Error": error
}
resp.content_type = 'application/json'
resp.media = response
print("Error: ", error)
return
resp.status = falcon.HTTP_200 # This is the default status
Функция, которая запускает процесс извлечения pdf:
async def send_response(file_name):
text = extract_text_by_page(file_name)
data = {
"data": list(text)
}
print("send text with: ", data)
Функция по парсингу пдфки:
def extract_text_by_page(file_name: str):
# some code
Ruslan
Приветствую.
Есть пандас датафрейм вида
id | vector
1 | [0,1,0,]
1 | [1,1,0,]
2 | [0,1,1,]
3 | [0,1,0,]
3 | [0,1,1,]
3 | [1,1,0,]
Необходимо произвести сумму векторов, сгруппировав по id.
Т.e. в результате ожидаю получить такой dataframe
1 | [1,2,0,]
2 | [0,1,1,]
3 | [1,3,1,]
Пробую делать это
grouped_train_df = ext_train_df.groupby('id').agg(lambda x: np.sum(x, axis=0))
но результат кривой - списки объединяются, т.е. получется
1 | [0,1,0,1,1,0,]
и так далее..
Есть идеи?
Oleksii
Парни, кто работал в google cloud api, были проблемы?
У меня клиент никак не пашет. Есть какой-то гайд для тупых? У меня по гугловскому не получается