@bergen said in xml код из zip файла модуля:
Печально, что нужно копаться во внутренней структуре модуля и скрипта БАС чтобы сделать нормальное преобразование в обратную сторону.
А как ты хотел? Вжииих и готово?😄
Нормальное завершение потока, из которого запускается асинхронная функция
-
Так не ждите выполнения асинхронной - там по сути просто гет запрос ... даже если в цикле ... По идеи вообще один ...
-
@thepappo said in Нормальное завершение потока, из которого запускается асинхронная функция:
В скрипте нужно отменять активации номеров. Если отменить номер незадолго после взятия, то сервис СМС вернет ошибку.
Я написал отдельный скрипт, который по API получает номера, которые вот-вот истекут и отменяет их. Скрипт запускается в цикле каждую минуту.
Например, номер дается на 20 минут, поток в скрипте у меня не может взять номер на это время, а может, к примеру на 5 минут максимум, значит я могу смело отменять все номера, которые были взяты более 15 минут назад.
5 минут взяты для примера. Я знаю, что я беру номер из сервиса, что-то там делаю, жду смс-ку и все это занимает у меня максимум эти самые 5 минут.
Сам скрипт ни о каких потоках, скриптах и так далее понятия не имеет и работает автономно.
import logging import os import datetime import time from dotenv import load_dotenv from smsactivate.api import SMSActivateAPI # Configure logging logging.basicConfig(level=logging.DEBUG) logger = logging.getLogger("[sms_activate]") # Load environment variables from .env file ABS_PATH = os.path.dirname(os.path.abspath(__file__)) load_dotenv() def main(api_key: str, threshold_seconds: int = 15 * 60): """ Main function to check and process active activations. Args: api_key (str): API key for SMSActivate service. threshold_seconds (int): Threshold in seconds to consider activation time. Returns: None """ sa = SMSActivateAPI(api_key) sa.debug_mode = True # Get active activations activations = sa.getActiveActivations() if activations.get("error") == 'NO_ACTIVATIONS': logger.info("No pending activations found.") return False # Check if activations retrieval was successful if activations.get("status") != 'success': raise Exception("Activation status is not success") # Loop through active activations for one in activations["activeActivations"]: if one["smsCode"]: # Skip if activation is already used continue # Parse activation time activation_time_str = one["activationTime"] activation_time = datetime.datetime.strptime(activation_time_str, '%Y-%m-%d %H:%M:%S') current_time = datetime.datetime.now() # Calculate time difference in seconds time_difference = current_time - activation_time seconds_difference = time_difference.total_seconds() # Log the time difference logger.info("Seconds difference from activation time to now: %s" % seconds_difference) # Check if activation time exceeds threshold if seconds_difference > threshold_seconds: logger.info("Activation time exceeds threshold for: %s" % one) # Mark activation as used sa.setStatus(id=one["activationId"], status=8) if __name__ == '__main__': # Get SMS Activate API key from environment variables sms_activate_api_key = os.getenv("SMS_ACTIVATE_API_KEY") if not sms_activate_api_key: raise Exception('SMS_ACTIVATE_API_KEY environment variable not set') sms_activate_api_key = sms_activate_api_key.strip() time_to_sleep = 60 while True: try: main(api_key=sms_activate_api_key) except Exception as e: # Log any exceptions logger.error(e) # Wait for 60 seconds before checking again logger.info(f"Sleeping for {time_to_sleep} seconds") time.sleep(time_to_sleep) -
@thepappo понял, во все просто оказывается ... Сергедрын взял и все по полочкам разложил ... Я правда его задачи до конца не понял, по какой причине поток не может взять больше чем на пять, и почему если он не дождался не может отбить что не судьба, но главное все по уму, по науке ....
-
-
@Nicolas said in Нормальное завершение потока, из которого запускается асинхронная функция:
Так не ждите выполнения асинхронной
В том и прикол, что я не жду. В предыдущем посте шаблон выложил тестовый, он нормально работает. А рабочий - нет ). Очевидно, что-то накосячил я сам.
-
@thepappo said in Нормальное завершение потока, из которого запускается асинхронная функция:
@sergerdn так а при чем тут питон?
Можно реализовать эту логику на каком угодно языке.
И получить тоже самое, один автономный скрипт отмены и куча скриптов на BAS, что берут номера из смс-сервиса и не имеют никакой логики отмены их. Я пишу всякие утилиты на python, ты можешь писать на чем угодно.
-
@thepappo said in Нормальное завершение потока, из которого запускается асинхронная функция:
@Nicolas said in Нормальное завершение потока, из которого запускается асинхронная функция:
Так не ждите выполнения асинхронной
В том и прикол, что я не жду. В предыдущем посте шаблон выложил тестовый, он нормально работает. А рабочий - нет ). Очевидно, что-то накосячил я сам.
в ошибку и на фейл внутри асинхронной ...
-
@sergerdn said in Нормальное завершение потока, из которого запускается асинхронная функция:
один автономный скрипт отмены и куча скриптов на BAS
Я понимаю, что можно. Я выше и про запуск демона из onApplicationStart писал. И я сам пишу на питоне ). Но в данном случае надо было именно из потока запускать таску.
