АТ
у меня они логируются, я там заметил ошибку)
Size: a a a
2021 March 17
АТ
ну тем более добавь например периодическое логгирование какие джобы есть
или мне на проде сделать принт 'scheduler.print_jobs' ?
<Ч
или мне на проде сделать принт 'scheduler.print_jobs' ?
я себе оставлю такую кнопку в админку, когда использую apscheduler, мало ли что, смогу моментально увидеть, что там вообще происходит
<Ч
а чтобы писать в лог, а не в файл сделал (ну ладно украл) небольшую обёртку
class StreamToLogger:
def __init__(self, in_logger):
self.logger = in_logger
self.linebuf = ''
def write(self, buf):
for line in buf.rstrip().splitlines():
self.logger.info(line.rstrip())АТ
я себе оставлю такую кнопку в админку, когда использую apscheduler, мало ли что, смогу моментально увидеть, что там вообще происходит
хорошо, спасибо
Но не знаешь почему если один процесс не отрабатывается ссылаясь на то что максимум 1 запрос может быть в процессе, как остальные отрабатывают нормально?
Думал может он просто долго отрабатывается, но в этот джоб вообще не заходит. Когда заходит должен в логах запринтить
Но не знаешь почему если один процесс не отрабатывается ссылаясь на то что максимум 1 запрос может быть в процессе, как остальные отрабатывают нормально?
Думал может он просто долго отрабатывается, но в этот джоб вообще не заходит. Когда заходит должен в логах запринтить
<Ч
хорошо, спасибо
Но не знаешь почему если один процесс не отрабатывается ссылаясь на то что максимум 1 запрос может быть в процессе, как остальные отрабатывают нормально?
Думал может он просто долго отрабатывается, но в этот джоб вообще не заходит. Когда заходит должен в логах запринтить
Но не знаешь почему если один процесс не отрабатывается ссылаясь на то что максимум 1 запрос может быть в процессе, как остальные отрабатывают нормально?
Думал может он просто долго отрабатывается, но в этот джоб вообще не заходит. Когда заходит должен в логах запринтить
не, не встречал, чтобы зависал джоб
<Ч
ну и то, что максимум настраивается, это думаю ты в курсе
D
с днем святого Патрика, парни
S
Всем доброго дня суток
Настраиваю ETL, нужен совет
я сначала делаю extract и transform в одной функции
а load в другой
соответсвенно полученный результат мне нужно передать из первой функции во вторую
Как лучше сделать: return df в первой функции и потом передать df во вторую
или df.to_csv и потом читать этот файл во второй функции?
Настраиваю ETL, нужен совет
я сначала делаю extract и transform в одной функции
а load в другой
соответсвенно полученный результат мне нужно передать из первой функции во вторую
Как лучше сделать: return df в первой функции и потом передать df во вторую
или df.to_csv и потом читать этот файл во второй функции?
S
чтобы быстрее работало
БГ
а чтобы писать в лог, а не в файл сделал (ну ладно украл) небольшую обёртку
class StreamToLogger:
def __init__(self, in_logger):
self.logger = in_logger
self.linebuf = ''
def write(self, buf):
for line in buf.rstrip().splitlines():
self.logger.info(line.rstrip())А чо, использовать StreamHandler уже зашквар?)
<Ч
А чо, использовать StreamHandler уже зашквар?)
ммм как это поможет собирать данные из входящего потока?
БГ
ммм как это поможет собирать данные из входящего потока?
Ааа, стоп, это вы про приём логов каким-то чем-то, да?
<Ч
Ааа, стоп, это вы про приём логов каким-то чем-то, да?
да, там метод принимает file-like параметр в который запишет нужные данные
БГ
да, там метод принимает file-like параметр в который запишет нужные данные
А отправляет кто как и куда?
<Ч
А отправляет кто как и куда?
ну это уже задача прикладного программиста. библиотека запишет в параметр и больше ни о чем не думает
БГ
ну это уже задача прикладного программиста. библиотека запишет в параметр и больше ни о чем не думает
Я просто про отправку средствами логгинга
<Ч
Я просто про отправку средствами логгинга
как надо так и отправляй, про это вопроса не было