Как отправлять данные на другой сервер с определённым периодом?

Question

[Александр]

Задача такова. Нужно отправлять данные с моего сервера на другой с определенным периодом времени, например, раз в час.
Думаю делать это примерно так: посылаю запрос /send-data?period=60 и данные начинают отправляться каждые 60 секунд. Потом через какое-то время отправляю запрос /stop-data и данные прекращают отправляться.
Вот так примерно думаю отправлять данные (кстати, пользуюсь flask):

def post_to_clojure():
    try:
        r = requests.post(config.uri)
        print r.raw
    except (RuntimeError, TypeError, NameError):
        print "Error while query request"
        
@app.route('/start-timer', methods=['GET'])
def start_timer():
  i = 0
  while i < 5: # пока запрос отправляется 5 раз, т.к. я не знаю как его потом остановить
    post_to_clojure()
    time.sleep(period) # вот тут задаём период отправки
    i = i + 1

@app.route('/stop-timer', methods=['GET'])
def start_timer():
    # как остановить, если отправка данные сейчас идёт???

Как видите, там пока цикл идёт до 5. Но как сделать бесконечный цикл, чтобы потом можно было его остановить запросом /stop-data? Либо может есть какой-то другой способ, чтобы данные отправлялись в фоновом режиме и я мог его потом остановить запросом? Подскажите, пожалуйста, самый оптимальный способ

Comments

[Сережа Ахен]

i = 1
while i = 1
(ничего больше с переменной не делаем)

А по команде стоп назначить переменной значение 0 и цикл остановится?
Предполагаю, я питона только по телевизору видел.

[Александр]

Сережа Ахен: Подскажите, как реализовать?

[GDApsy]

Александр Вербер: а посмотрите в сторону https://docs.python.org/3/library/asyncio.html . Пример с SO переодического выполнения задачи: https://stackoverflow.com/questions/37512182/how-c... Нужен минимум Питон 3.4, а лучше 3.5

[sim3x]

GDApsy: зачем тут асинк?

[GDApsy]

Затем что это долгоиграющая задача в веб-приложении и не слишком приятно, если она заблокирует обработчик при превышении, например, времени ожидания ответа.

[sim3x]

GDApsy: тем более непонятное зачем тут асинк, если есть селера

[GDApsy]

sim3x: а откуда есть сведенья что есть Celery?

[sim3x]

GDApsy: ?

[GDApsy]

>если есть селера

Под селерой тогда что имеется ввиду?

[sim3x]

GDApsy: www.celeryproject.org

[GDApsy]

Правильно, так вопрос откуда информация что эта система уже есть в проекте? И зачем ее втаскивать в проект, если асинка встроена уже и может управлять периодическими задачами?

[Александр]

GDApsy: я написал вот такой код, но сервер (iis 7.0) выдаёт ошибку 408 request time-out
https://pastebin.com/HQtLaKUE
Например, если пишу через браузер запрос http://localhost:port/start-timer , он грузится до тех пор, пока не произойдёт вылет по таймауту. А в идеале нужно, чтобы после отправки запроса, запустился процесс автоматической отправки запросов с определенным периодом и позже я его смог остановить по запросу http://localhost:port/stop-timer
Как это сделать?

Answer 1

[Олег]

Если идти в лоб по наводке Сережа Ахен + использовать исходно приведенный код. Наверняка есть более красивое решение (например, мне категорически не нравится запускать фоновую работу в основном потоке Flask):

i = 0

def post_to_clojure():
    try:
        r = requests.post(config.uri)
        print r.raw
    except (RuntimeError, TypeError, NameError):
        print "Error while query request"
        
@app.route('/start-timer', methods=['GET'])
def start_timer():
  global i
  i = 1
  while i == 1:
    post_to_clojure()
    time.sleep(period)

@app.route('/stop-timer', methods=['GET'])
def stop_timer():
    global i
    i = 0

Comments

[Александр]

Да, сначала не совсем понял его наводку