да хуй его знает

ахуенно, Игорь)

from multiprocessing.dummy import Pool p = Pool(30) p.map() #1 p.map_async() #2 Чем отличаются 1 от 2?

че те 5 центов жалко

че те 5 центов жалко

ну так они не мои

у нас акк компании

Че те чужие 5 центов жалко?

ггггг

https://aws.amazon.com/dynamodb/pricing/ https://aws.amazon.com/dynamodb/faqs/#What_is_a_readwrite_capacity_unit

я это прочитал все

вопрос мой глянь

хмммм, смотрите. В бесплатный пакет амазоновской noSQL идет 25 единиц ресурса записи. То бишь если я гружу файл весом в 100 кб, он у меня будет грузиться 4 секунды или затратит 100 единиц ресурса записи и загрузит 1 секунду?

главное - не парься, если потом придет счет - заредиректишь на менеджера

from multiprocessing.dummy import Pool p = Pool(30) p.map() #1 p.map_async() #2 Чем отличаются 1 от 2?

асинк тебе сразу управление вернет

и потом надо тыкать палкой пул емнип

@Enchantner Тут снова я)0))

@Enchantner Тут снова я)0))

чо чо? :)

while True блокирует петлю?

Мне нужно, чтобы mining_subscribe не блокировал handle_miner

у тебя внутри while await, так что блокировать не должно, по идее

Фигушки

Он заходит в цикл, и сервер перестает читать новые сообщения

Он заходит в цикл, и сервер перестает читать новые сообщения

Ну запили второй луп тогды

Я пытаюсь разобраться как поступать в подобных ситуациях

Ведь оно по идее и в одном лупе должно прекрасно работать

Ну по идее гет джоб всегда должен давать какой-то хороший ответ, чтобы убрать while

Он заходит в цикл, и сервер перестает читать новые сообщения

у тебя оно виснет на уровне get_job() или на уровне from_rpc_template?

Вот этот цикл все блокирует

while True: template = ZCashBlockTemplate.from_rpc_template(await self.get_job())

while True: template = ZCashBlockTemplate.from_rpc_template(await self.get_job())

Колян, прав что-то внутри блочит, а не while

ensure_future() нужно для запуска mining_subscribe?

Или я могу просто await написать?

погоди

ты хочешь несколько инстансов mining_subscribe "параллельно" запустить?

Один

Но он должен работать параллельно с handle_miner

тогда тебе нужен шедулер внешний, как вариант

засунь их оба в asyncio.ensure_future() и не пиши сразу к нему await, а дерни снаружи gather() на их оба

тогда все будет, как ты хочешь

засунь их оба в asyncio.ensure_future() и не пиши сразу к нему await, а дерни снаружи gather() на их оба

Неужели это как-то красиво не решается? Прост таких кусков в коде много будет

ну то есть как-то так: await asyncio.gather( asyncio.ensure_future(mining_subscribe(writer)), asyncio.ensure_future(handler_miner(reader, writer))] )

Да, но первая функа должна вызываться из второй

пацаны

вас когда-нибудь увольняли?

вас когда-нибудь увольняли?

Обычно сразу в тюрьму.

Да, но первая функа должна вызываться из второй

какой в этом смысл, если в обеих вечный луп?

какой в этом смысл, если в обеих вечный луп?

Первая читает сообщения, и если есть нужное, вызывает функцию

Первая читает сообщения, и если есть нужное, вызывает функцию

тогда зачем у тебя вечный луп в вызываемой вообще?

Чтобы читать сообщения

КО

погоди

Это сокет

ты дергаешь в вечном лупе функцию, в которой другой вечный луп

мне кажется, ты озалуплен

Лол

Возможно

я потому и говорю - у тебя два воркера, один на чтение, один на обработку

Там повыше уровнем обработчики исключений

так?

если да - тогда запускай их параллельно и сделай между ними очередь, например

но дергать в бесконечном лупе другой бесконечный луп - это жесть

удивительно, что проц не сжирает тут же на 100%

несмотря на асинхронность

ERROR: S client not available

Бля, обожаю asyncio

Заставляет задуматься о бытие

Кидает что не дефайнд

ну почему же вы шлете код скриншотами, мистер Андерсон?

Ну...

*разводит руками*

Ну так как-то можно получить закешированный вывод?

а по поводу кода, а где у тебя ASF определяется?

43 строка

либо сделать глобальной переменной, либо передать в конструктор класса

Ок, глобальной сделаю

я только не понял, нафига у тебя там вечный цикл

а по поводу кода, а где у тебя ASF определяется?

о, увидел

я только не понял, нафига у тебя там вечный цикл

Ну пусть кеширует пока не сдохнет

Все равно sleep(30)

да он у тебя вроде не дойдет до while

Ну пусть кеширует пока не сдохнет

там ничего не кэширует никто, ты просто тыщу раз пересоздаешь один и тот же объект

и да, сейчас скажут, что я запарил и не оригинален

но, блин, в таких задачах хорошо подходит aiohttp

там ничего не кэширует никто, ты просто тыщу раз пересоздаешь один и тот же объект

Там кеш делается моей библиотекой

Которая общается с другой программой

class GetHandler(BaseHTTPRequestHandler): def do_GET(self): global ASF page = '' count = 0 for bot in ASF['Bots']: count += 1 botf = ASF['Bots'][bot]["CardsFarmer"] if not botf['CurrentGamesFarming'] == []: game = botf["CurrentGamesFarming"][0] page = page + botpart % (bot, game['GameName'], game['AppID'], game[ 'HoursPlayed'], game['CardsRemaining'],botf['TimeRemaining']) else: page = page + botpart_nothing % (bot) self.send_response(200) self.end_headers() self.wfile.write(bytes(mpage % (count, infofetched, page), 'utf-8')) return if __name__ == '__main__': server = HTTPServer(('', 8000), GetHandler) print('Starting server, use <Ctrl-C> to stop') server.serve_forever() while 1: global ASF ASF = api.receiveAPI() infofetched = strftime("%b %d %Y %H:%M:%S", time()) sleep(30)

@Enchantner Поясни, serve_forever разве не блокирует поток?

што я не так сделал?

Все равно кидает еррор

@Enchantner Поясни, serve_forever разве не блокирует поток?

я не помню навскидку, но вроде да, должен

@Enchantner Поясни, serve_forever разве не блокирует поток?

Стоп, точно

Как это обойти?

што я не так сделал?

ты все не так сделал, если у тебя вызов api.receiveAPI() что-то кэширует - это плохо, не надо так делать

Хотя вроде надо переделать его в threaded

Стоп, точно

тебе что нужно? получать данные от апи по таймеру?