Как проверить, завершен ли процесс на сервере?

Question

[Василий Васильев]

Пилю приложение, которое на бэке раз в, например, 5 минут выполняет некое асинхронное действие, которое может выполняться разное время. Из-за технических ограничений действие будет запускаться пингованием сервера извне(т.е. цикл, каждая итерация которого запускается пингом сервера. При этом итерация может занимать разное время, иногда больше пяти минут). Как проверить при пинге, завершился предыдущий цикл или нет? Или может есть более разумное решение?

Comments

[Василий Васильев]

Может создать что-то вроде очереди команд, пингованием добавлять команду в очередь. Но как это сделать правильно?

[Владимир]

Именно пингом прям который пинг? Никакой возможности кинуть http запрос?

[Kovalsky]

В текущем виде мне кажется самым простым решением будет иметь какой-нибудь флаг типа refresh_completed = true | false, или чо-нибудь такое. Но если вы внятно расскажете какую задачу решаете, то думаю ответы будут более конструктивные

[Василий Васильев]

Владимир, можно и запросом. Имеется ввиду что только извне

[Василий Васильев]

Kovalsky, надо чтоб сервер в определенные промежутки времени опрашивал список сайтов. Опрос настроил, залил сервер на heroku, а с расписанием возникли проблемы. Думал использовать Heroku Scheduler, но он отпал сразу из-за отсутствия кастомного времени(например, 5 минут) и отсутствия гарантии запуска задачи. Придумал пинговать извне(например, аптайм роботом), отсюда и данный вопрос возник.

[Kovalsky]

"он отпал сразу из-за отсутствия кастомного времени" - в смысле?

Конкретно у него действительно нету возможности задать кастомное время типа 5 минут, но во первых там есть возможность выполнить скрипт каждые 10 минут или каждый час, и к тому же Heroku Scheduler не единственный планировщик там,

[Владимир]

Basil_Dev, тогда просто возвращайте на запрос код 200 когда работа сделана и, скажем, 418 пока нет.

Answer 1

[Сергей Соколов]

Семафор: записывать process_id (pid) в текстовый файл.
Обработчик пинга смотрит, есть ли файл, читает из него pid и смотрит, жив ли такой процесс. Если нет – запускает задачу и записывает её pid в файл.
При завершении обработки задачи файл удаляется.

Answer 2

[aarifkhamdi]

ваш бэкенд сам может определить завершил он асинхронное действие или нет?

если ваш бэк не знает, то другой сервис, который использует бэк, тем более не сможет это узнать!

а если бэк знает, то просто при пинге отвечаете 400 "предыдущая операция не завершена" и 200 "взялся за работу" соответственно

Comments

[Stalker_RED]

тогда уж 425, а не 400

Answer 3

[Kovalsky]

Из текста вопроса понятно, что ТС пытается решить проблему уже не раз решенную в рамках Heroku (тк сервису уже достаточно много годиков), по этому поводу решил проверить сам как оно всё работает: создал учетку на хероку, создал задачку для Heroku Scheduler которая тянет из интернетов список персонажей из рика и морти, поднял приложение которое отдаёт случайного персонажа из скачанного списка,

Из всего этого следует, что нативные для Heroku инструменты прекрасно справляются с поставленной задачей. Если хочется обязательно иметь интервал 5 минут, то благо Heroku Scheduler не единственный, можно использовать например Advanced Scheduler или вообще Custom clock process. Clock process это очень мощная штука, с ней вы можете что угодно реализовать

Answer 4

[Igor Scherbakov]

Попробуйте использовать в качестве планировщика задач node-schedule. Написал пример, как можно решить вашу задачу

const schedule = require('node-schedule');
const lowdb = require('lowdb');
const FileSync = require('lowdb/adapters/FileSync');

// Local database for saving jobs state
const db = lowdb(new FileSync('./jobs.json'));
db.defaults({ jobs: [] }).write();

const jobManager = {
  // Retrieving jobs from database and check if has active job
  hasActive: () => db.get('jobs').find((job) => job.isActive).value(),
  // Add active job
  add: () => {
    const [lastJob] = db.get('jobs').takeRight(1).value();
    db.get('jobs').push({ id: lastJob ? lastJob.id + 1 : 0, isActive: true }).write();
  },
  // Finish active job
  finish: () => {
    const [lastJob] = db.get('jobs').takeRight(1).value();
    db.get('jobs').find({ id: lastJob.id }).assign({ isActive: false }).write();
  }
};

// Your heavy async job
const job = async () => {
  if (!jobManager.hasActive()) {
    jobManager.add()
    console.log('Heavy job ...');
    jobManager.finish()
  } else {
    return 'Skipped, because you have active job now. Expect for current job finish';
  }
};

// Recurrence job at every 5 minutes
schedule.scheduleJob('*/5 * * * *', async () => {
  job().then((response) => console.log(response));
});