Добрый день!
Подскажите, как мне сделать async http запросы с ответом.
Т.е я хочу сделать запрос по нескольким Url, дождаться от всех ответ, собрать в табоицу и вернуть ответ исходному клиенту (который делал запрос в tarantool)?

В файберах поделать.

Можно ответы в fiber channel положить и вычитывать оттуда, можно файберы сделать joinable.

Спасибо, буду изучать как это все вмести собрать и реализовать.

Мы это в тренингах показываем, сейчас найду вам пример

я такое на собесах иногда спрашиваю

они новые записи по спейсам перекладывают) точнее - каждую новую запись. и сейчас там стоит 20мс таймаут. я тут просто думаю, что эффективнее вообще - небольшой sleep или yield, или yield + sleep

yield = sleep(0)

ну файберы без слипа(один йилд) вроде подвешивали инстанс. а вот есть ли смысл йилдить при условии, что раз в n таплов или если таплы для обработки закончились, файбер уснет - пока не ясно

Спасибо!

мы как-то подбирали на 2660, что если yield'ить раз в 700 таплов на 0 секунд, инстанс потребляет почти 100% CPU, но при этом полноценно отвечает. Как правило, если нужно просканить индекс и посчитать простенькие агрегаты над данными, обычно yield'ят раз в 200-300 таплов на 10мс. Это достаточно легко профилируется, просто запускаете такие файберы и смотрите на потребление, а также на среднее время исполнения других запросов. Также, хорошей практикой является вынесение таких констант в некоторое глобальное пространство или конфиги, чтобы можно было модифицировать в рантайме (с разумными ограничениями на минимальные/максимальные границы)

ну пока подбирал, как раз вынес, чтобы не шариться по всему коду. а за инфу спасибо, буду пожалуй из этого и исходить. только еще один уточняющий вопрос: вставка пачки таплов в транзакции по скорости же вроде должна быть экономнее, чем по одному?

да, потому что в wal отдаете сразу пачку изменений, и не прыгаете туда-обратно на каждую запись

Если
quota_used_ratio = 60.0
items_used_ratio = 99.9
это же норм?

да

спс

Заглянул тут в реализацию raft

@gerold103 txn_limbo_ack имеет сложность N*M

где N - число событий в очереди, M - число реплик.