184 похожих чатов

Подскажите, кто пользует dbt, можно ли парралелить запросы по шардам?

Сейчас данные шардированы по приложениям и мы в самописном пайплайне просто запускаем одинаковый запрос в отдельном потоке на каждый шард, можно ли что-то такое сделать в dbt для ускорения?

7 ответов

26 просмотров

Прописываете в profiles.yml подключение к каждому шарду и используете при dbt run флаг --target *название таргета для шарда*. И так на каждый шард. Распараллелить можете в том же эйрфлоу, по таске на каждый шард

Konstantin Ilchenko- Автор вопроса
Дмитрий Володин
Прописываете в profiles.yml подключение к каждому ...

Спасибо, а если усложнить, и надо много запросов на 1 шард, например разбиваем 1 жирный запрос чтобы в память укладывался через where app_id % 30 = {0..29}. Через dbt run --vars нормально делать? + автогенерация тасок в airflow

Konstantin Ilchenko
Спасибо, а если усложнить, и надо много запросов н...

dbt_users DBT users group Взаимное уважение и без спама. Для вакансий тег #job Dual language: russian/english https://t.me/dbt_users Вполне живое русскоязычное комьюнити. Там был ответ про union_relations макрос

Konstantin Ilchenko- Автор вопроса
Дмитрий Володин
dbt_users DBT users group Взаимное уважение и без...

Спасибо, изучу, но на первый взгляд это что-то для объединения, а не разбития запроса)

Konstantin Ilchenko- Автор вопроса
Дмитрий Володин
Ну а объединять-то данные потом как будете?))

так они пишут в 1 таблицу, объединять ничего не надо) Просто 1 запрос на вставку разбивается на 30 маленьких

Konstantin Ilchenko
так они пишут в 1 таблицу, объединять ничего не на...

Короче, почитайте. Может это то, что нужно. У меня таких проблем не возникало, только при initial load. Там тупо циклом с переменным делал

Похожие вопросы

Обсуждают сегодня

Господа, а что сейчас вообще с рынком труда на делфи происходит? Какова ситуация?
Rꙮman Yankꙮvsky
29
А вообще, что может смущать в самой Julia - бы сказал, что нет единого стандартного подхода по многим моментам, поэтому многое выглядит как "хаки" и произвол. Короче говоря, с...
Viktor G.
2
30500 за редактор? )
Владимир
47
а через ESC-код ?
Alexey Kulakov
29
Чёт не понял, я ж правильной функцией воспользовался чтобы вывести отладочную информацию? но что-то она не ловится
notme
18
У меня есть функция где происходит это: write_bit(buffer, 1); write_bit(buffer, 0); write_bit(buffer, 1); write_bit(buffer, 1); write_bit(buffer, 1); w...
~
14
Добрый день! Скажите пожалуйста, а какие программы вы бы рекомендовали написать для того, чтобы научиться управлять памятью? Можно написать динамический массив, можно связный ...
Филипп
7
Недавно Google Project Zero нашёл багу в SQLite с помощью LLM, о чём достаточно было шумно в определённых интернетах, которые сопровождались рассказами, что скоро всех "ибешни...
Alex Sherbakov
5
Ребят в СИ можно реализовать ООП?
Николай
33
https://github.com/erlang/otp/blob/OTP-27.1/lib/kernel/src/logger_h_common.erl#L174 https://github.com/erlang/otp/blob/OTP-27.1/lib/kernel/src/logger_olp.erl#L76 15 лет назад...
Maksim Lapshin
20
Карта сайта