Я не часто использовал python, поэтому не уверен, как бы я это сделал. Вот логика, которую мне нужно реализовать.
- Позвоните в Службу 1 для получения идентификатора заказа
- Используйте этот order_id для вызова AWS Athena для получения данных
- Используйте этот order_id для вызова еще 2 внутренних служб для получения данных
- Объединение данных из точек 1 и 2 в 1 файл (общий процесс может генерировать больше файлов, каждый файл не может иметь более 100 000 записей).
Теперь я не уверен, как мне реализовать пункт 2, 3 в python. Я также не уверен, как я могу убедиться, что только 1 поток в любой момент времени записывает в файл.