Описание тега highland.js
The high-level streams library for Node.js and the browser.
3
ответа
Невозможно получить данные из mongodb из результатов, используя streams/highland.js
Я новичок в потоках, и я пытаюсь получить данные из моей коллекции, используя реактивный-superglue / highland.js ( https://github.com/santillaner/reactive-superglue). var sg = require("reactive-superglue") var query = sg.mongodb("mongodb://localhost…
29 апр '16 в 18:45
1
ответ
Как создать поток объектов из удаленного массива JSON через Highland?
Извлечение JSON из URL http://foo.bar/overview с помощью: const request = request.get('http://foo.bar/overview'); дает в ответе JSON, содержащий массив объектов: [ { id: 1, narf: 'foo', poit: 'bar', }, { id: 2, narf: 'fizz', poit: 'buzz', }, ] Сейча…
11 дек '16 в 14:34
1
ответ
Как я могу прочитать поток объектов JSON в браузер
Учитывая node.js поток объекта стиля, как показано в примере ниже, как это может быть прочитано http запрос на сайте и обработан: {"id":"one", "value":"the first object"} {"id":"two", "value":"the second object"} {"id":"three", "value":"the third ob…
24 окт '16 в 13:24
1
ответ
Highland потребляют и метод toArray вместе
Привет людям и счастливых праздников! Я пытаюсь использовать поток строк CSV с горной местности. Чтобы выполнить специальную обработку и избежать передачи заголовков в поток, я звоню .consume() и тогда я хотел получить результат в массиве. Проблема …
27 дек '17 в 02:04
1
ответ
Чтение большого файла и метод splitby
Я пытаюсь использовать splitby метод в highland.js извлечь данные между начальным и конечным разделителями. -----BEGIN DATA----- MIIEzDCCArSgAwIBAgIVCugKYzMN5ra8zPWxYE8pUU9SxjYSMA0GCSqGSIb3DQEB CwUAMHAxCzAJBgNVBAYTAkdCMRUwEwYDVQQIDAxXYXJ3aWNrc2hpcmU…
14 сен '16 в 22:07
0
ответов
Справиться с обратным давлением мангусты при получении документов
Я использую нагорье, чтобы справиться с давлением. Мой код: const pipeline = [{ $match: { 'published': true, status: 'Approved' } }]; const cursor = UserModel.aggregate(pipeline) .cursor().exec(); // iterating over each hospitality one by one highla…
03 май '18 в 11:46
1
ответ
Highland.js для разбора CSV
Я пытаюсь написать очень функциональную манеру. Мы используем Highland.js для управления потоковой обработкой, однако, поскольку я настолько новичок, я думаю, что я действительно путаюсь с тем, как я могу справиться с этой уникальной ситуацией. Проб…
01 апр '15 в 15:52
1
ответ
highland.js асинхронный массив для потока значений
Я пытаюсь получить следующие фрагменты, чтобы вернуть тот же вывод - поток значений массива. Первый метод начинается с массива и выдает значения. Второй метод получает в качестве входных данных обещание, которое разрешает массив, поэтому вместо выда…
01 апр '16 в 14:08
0
ответов
Добавление вилок после запуска потока?
У меня есть приложение node.js, использующее поток Highland. Он использует источник данных и должен отправлять данные в несколько пунктов назначения. Проблема в том, что места назначения обнаруживаются динамически путем чтения данных и создания пото…
09 авг '16 в 17:26
2
ответа
Как я могу читать из горного ручья?
Итак, у меня есть горный поток: var getData = highland.wrapCallback(fs.readFile); var fileStream = getData('myfile') console.log(fileStream) Как читать из fileStream? Согласно документам Highland, нет read() метод на потоках.
11 апр '14 в 12:03
3
ответа
mocha с nodejs assert зависает / тайм-ауты для assert(false) вместо ошибки
У меня есть такой тест мокко: describe 'sabah', → beforeEach → @sabahStrategy = _.filter(@strats, { name: 'sabah2' })[0] .strat it 'article list should be populated', (done) → @timeout 10000 strat = new @sabahStrategy() articles = strat.getArticleSt…
06 ноя '14 в 01:38
1
ответ
Сделайте что-нибудь перед использованием потока, используя highland.js
Я пытаюсь закодировать поток для записи, который берет поток объектов и вводит их в базу данных mongodb. Прежде чем использовать поток объектов, мне сначала нужно дождаться установления db-соединения, но я, похоже, что-то делаю не так, потому что пр…
08 мар '16 в 13:06
2
ответа
Асинхронная карта с Highland.js
У меня есть поток Highland, который периодически получает данные с сервера. Мне нужно сделать поиск базы данных внутри карты. Я не могу найти упоминаний о том, чтобы сделать что-то асинхронное в каком-либо из трансформаторов Хайленда.
28 апр '15 в 09:19
1
ответ
Highland добавить в поток, прежде чем полностью потребляется?
Есть способ добавить в поток высокогорья законченное сообщение с полным описанием наших потребностей? Меньше предположим, что мы имеем следующую ситуацию: const stream = high([1,4,6,7]) Затем с этим потоком я хочу подсчитать каждое из обрабатываемых…
24 июл '18 в 16:15
2
ответа
Управление зависимостями в node.js с помощью highland.js
Я получаю огромное значение от node.js и обожаю модель потоковой обработки. Я в основном использую его для потоковой обработки с обогащением данных и ETL-подобных заданий. Для обогащения у меня может быть такая запись... { "ip":"123.45.789.01", "pro…
19 авг '15 в 18:22
1
ответ
Добавить заголовки в CSV и вернуть строку с соответствующей строкой в Node.js
Я пытаюсь вернуть значение строки в соответствующей строке. Я начинаю с CSV, который не имеет подробности заголовка. После загрузки CSV в память, я думаю, что мне нужно сначала добавить заголовки, а затем преобразовать данные в JSON, а затем перебра…
28 июн '18 в 13:37
0
ответов
Буфер через файл
У меня есть сценарий, когда мой производитель работает намного быстрее, чем мой потребитель с большим количеством данных. Однако я не хочу блокировать продюсера. Таким образом, единственный вариант - буферизовать дополнительные данные через файл. Мн…
24 апр '15 в 16:46
2
ответа
Как раскошелиться поток, используя highland.js?
У меня есть sourceStream состоящий из BaseData объекты. Я хочу раскрутить этот поток в nколичество различных потоков, которые затем фильтруют и преобразуют каждый BaseData возразить по своему вкусу. В конце концов, я хочу иметь n потоки, содержащие …
06 фев '17 в 17:38
1
ответ
Как преобразовать высокогорный поток в поток, читаемый узлом?
У меня есть струйные струны из горного ручья. Я хочу использовать его из внешней библиотеки (в моем случае Amazon S3), и для его SDK мне нужен стандартный узел Readable Stream. Есть ли способ превратить поток Highland в ReadStream из коробки? Или я …
16 янв '17 в 14:48
1
ответ
ПапаПарс и Хайленд
Мне нужно проанализировать очень большой CSV-файл в NodeJS и сохранить его в базе данных (асинхронная операция), которая допускает до 500 записей одновременно. Из-за ограничений памяти я должен передавать файл CSV и использовать PapaParse для анализ…
05 фев '18 в 22:37