pipelinedb

0熱度

1回答

當我在管道中創建一個流並開始佔用一個主題時，它不會出現在我的主題的活動consmidores中，我該怎麼做以便它出現在那裏？ No consumer appears 如何創建的流 CREATE STREAM pipeline_kafka.summary_device_stream(pack json); SELECT pipeline_kafka.consume_begin('topicSumm

0熱度

1回答

pipelinedb無法識別的節點類型：5009

我從創建連續轉換的任何客戶端，但psql的問題。重現： OS：OSX埃爾卡皮坦10.11.6 多克爾版本17.09.0策，建立afdb6d4 docker run -d -p 5432:5432 pipelinedb/pipelinedb 現在，我通過連接到數據庫PHPStorm 2017.2，可以。我創造一些與流查詢： CREATE STREAM some_stream (id INT, a

0熱度

1回答

在RaspberryPi上編譯PipelineDB 2

我試圖在運行Raspbian的RasberryPi 2上編譯PipelineDB。我按照說明安裝了ZeroMQ。我得到這個錯誤： In file included from ../../../../src/include/pgstat.h:18:0, from brin.c:29: ../../../../src/include/pipeline/scheduler.h:53:

1熱度

3回答

如何從pipelinedb中的連續視圖輸出流？

我已經安裝了pipelinedb，它工作的很棒！我想知道在更新視圖中的值後，是否有可能將數據從連續視圖中流出？也就是說，有一些外部過程對視圖的更改起作用。我希望將從視圖生成的度量流傳送到儀表板，我不想使用輪詢數據庫來實現此目的。

0熱度

1回答

自定義PipelineDB擴展

目前我可以看到對kafka和kinesis的支持，是否可以將自定義協議擴展添加到pipelinedb？如果是的話，我在哪裏可以找到一些準則來編寫它。 - 感謝

1熱度

1回答

PipelineDB：鑑於連續輸出流意外顯示相同的（舊）和（新）值

我使用PipelineDB 0.9.7u3 我打了繼續觀看輸出流一點點地發現，如果我能得到一個新的連續查看一些更新。這是我的測試用例。 CREATE STREAM stream_test(ticketid text, val int, status text); -- simple continuous view on stream_test CREATE CONTINUOUS VIEW

4熱度

2回答

由於獲取事務標識

，因熱備服務器上的只讀查詢失敗，我們只是成功將一個主服務器備份到熱備服務器上。然而，當我們試圖查詢到雙機熱備，我們得到以下錯誤： ERROR: cannot assign TransactionIds during recovery 我啓用詳細模式，並看到varsup.c出現錯誤：72 /* safety check, we should never get this far in a HS

0熱度

1回答

PipelineDB，得到最高K項數

如何計算頻率最高K值在流中？比方說，我們有一個流 CREATE STREAM stream ( value number ); 我們插入十行 INSERT INTO stream (value) VALUES (1) INSERT INTO stream (value) VALUES (1) INSERT INTO stream (value) VALUES (1) INSE

0熱度

1回答

插入的默認日期在連續轉換中不會更改

我創建了下表。 create table foo ( ibutton text NULL, severidade int4 NULL, dt_insercao timestamptz NULL DEFAULT now() ) 我插入： insert into foo (ibutton, severidade)values ('aa', 4); 對於 'dt

2熱度

1回答

我們可以將數據添加到pipelinedb外部的連續視圖中嗎

我想將數據添加到特定的連續視圖。我不想通過這個流來提供它，因爲我只想將它添加到這個特定的視圖中，而不會讓其他人感到不安。我試過直接向cv_mrel表中添加行，但是我無法像某些列的視圖是hll（hyperloglog）類型。是我通過一個值創建/轉換爲此數據結構的任何方式或函數？