Size: a a a

NestJS — русскоязычное сообщество

2020 August 12

GG

Go Go in NestJS — русскоязычное сообщество
Но там нужно мониторинг делать самому и ack если это важно
источник

GG

Go Go in NestJS — русскоязычное сообщество
Для pub/sub кейсов хорош
источник

VA

Veaceslav Artiom in NestJS — русскоязычное сообщество
Я вот тоже смотрю в его сторону. Мне как бы сильно не нужно если сервис упал потом досылать сообщения или что-то такое.
источник

AK

Alex Kulagin 🏡 in NestJS — русскоязычное сообщество
А, кстати если будешь брать кафку, то старайся не использовать для каких-то сложных случаев. Клиенские библиотеки - это довольно убогие порты с java
источник

GG

Go Go in NestJS — русскоязычное сообщество
Veaceslav Artiom
Я вот тоже смотрю в его сторону. Мне как бы сильно не нужно если сервис упал потом досылать сообщения или что-то такое.
Если ack нужен используется nats-streaming server
источник

VA

Veaceslav Artiom in NestJS — русскоязычное сообщество
Спасибо господа. Пока что наверное пойду я дальше с NATS если чет не так будет, поменяю брокера.
источник

АД

Александр Духновский... in NestJS — русскоязычное сообщество
Для кафки дополнительную инфру нужно разворачивать. Если у тебя нагрузки до 20к rpc то бери кролика, если выше - кафку.
источник

AK

Alex Kulagin 🏡 in NestJS — русскоязычное сообщество
Александр Духновский
Для кафки дополнительную инфру нужно разворачивать. Если у тебя нагрузки до 20к rpc то бери кролика, если выше - кафку.
Конфлюент по приемлемым ценам раздаёт кафку
источник

АД

Александр Духновский... in NestJS — русскоязычное сообщество
Alex Kulagin 🏡
Конфлюент по приемлемым ценам раздаёт кафку
латенси меньше, если она развернута в твоем окружении, а не во внешнем
источник

AK

Alex Kulagin 🏡 in NestJS — русскоязычное сообщество
Эт да. Но я тестил из узб в дц на западном побережье и скорость обработки обработки туда-обратно была очень хорошая. В цифрах не скажу уже
источник

AK

Alex Kulagin 🏡 in NestJS — русскоязычное сообщество
Плюс есть helm чарт их же и примеры для docker-compose
источник

GT

Gleb Tregubov in NestJS — русскоязычное сообщество
Ребят, доброго времени суток!
Можете объяснить, почему данный код вызывает ошибку:
  async createWallet(walletCreateDto: WalletCreateDto): Observable<any>
 {
   this.logger.log(walletCreateDto)
   const result = await this.walletMicroServiceClient.emit('btc_message', walletCreateDto);
   console.log(result);
   return result;
 }


Это микросервис. Хочу увидеть результат, который мне вернул клиент, но получаю ошибку следующего типа: "The return type of an async function or method must be the global Promise<T> type."

Внедряясь вглубь времен, раскопал следующее: "Type '{ error: boolean; message: string; }' is not assignable to type 'Observable<{ error: boolean; message: string; }>'.
 Object literal may only specify known properties, and 'error' does not exist in type 'Observable<{ error: boolean; message: string; }>'."

То бишь, я типа возвращаю не Observable, а нечто иное. А как мне вернуть обзёрваул?
источник

🏡K

🏡 ILshat Khamitov in NestJS — русскоязычное сообщество
Gleb Tregubov
Ребят, доброго времени суток!
Можете объяснить, почему данный код вызывает ошибку:
  async createWallet(walletCreateDto: WalletCreateDto): Observable<any>
 {
   this.logger.log(walletCreateDto)
   const result = await this.walletMicroServiceClient.emit('btc_message', walletCreateDto);
   console.log(result);
   return result;
 }


Это микросервис. Хочу увидеть результат, который мне вернул клиент, но получаю ошибку следующего типа: "The return type of an async function or method must be the global Promise<T> type."

Внедряясь вглубь времен, раскопал следующее: "Type '{ error: boolean; message: string; }' is not assignable to type 'Observable<{ error: boolean; message: string; }>'.
 Object literal may only specify known properties, and 'error' does not exist in type 'Observable<{ error: boolean; message: string; }>'."

То бишь, я типа возвращаю не Observable, а нечто иное. А как мне вернуть обзёрваул?
from(result)
источник

🏡K

🏡 ILshat Khamitov in NestJS — русскоязычное сообщество
  createWallet(walletCreateDto: WalletCreateDto): Observable<any>
 {
   this.logger.log(walletCreateDto)
   return from(this.walletMicroServiceClient.emit('btc_message', walletCreateDto)).pipe(tap(consoel.log));
 }
источник

GT

Gleb Tregubov in NestJS — русскоязычное сообщество
Секундочку
источник

🏡K

🏡 ILshat Khamitov in NestJS — русскоязычное сообщество
что это такое не знаю this.walletMicroServiceClient.emit, в данном примере я предполагаю что метод возвращает промис
источник

GT

Gleb Tregubov in NestJS — русскоязычное сообщество
А он возвращает await.
источник

GT

Gleb Tregubov in NestJS — русскоязычное сообщество
Так подойдет?
источник

🏡K

🏡 ILshat Khamitov in NestJS — русскоязычное сообщество
нет)
источник

🏡K

🏡 ILshat Khamitov in NestJS — русскоязычное сообщество
нет такого типа
источник