time-series 相关问题

QuestDB包装结果每1000行？

SELECT x, timestamp_sequence( to_timestamp('2021-01-02T00:00:00', 'yyyy-MM-ddTHH:mm:ss'), 86400000000L) FROM long_sequence(2100);

我可以从Web控制台或使用Python

但是，当我尝试直接调用API时，我会发现一个错误：< dateadd('M', -8, date_trunc('day', now())) But when I try

我们正在使用QuestDB和读取Python的数据。它的行为通常很好，但是每当我们同时启动许多查询时，我们都会出现桌子繁忙的错误。 psycopg2.databaseerror：[-1]：表

table busy

如何修复/重置减少时间戳，同时保留用于CNN培训的时间序列数据的差距？ 我目前正在尝试从一项从蜜蜂收集视频数据的研究中进行预处理数据。 我遇到了一些问题，即记录的问题...

可以在这个小样本中显示这一点

防止时间序列工作负载的最佳方法是什么？ 我们使用scylla，但与Cassandra相同 Doc关于TWC说： 警告 不惜一切代价避免覆盖数据并明确删除数据，因为这可能会阻止过期的sstable

MongoServerError：“ Timestamp_property”必须存在并包含有效的BSON UTC DateTime值

在这里是我测试的代码：

使用ILP Python客户端时，某些数据未写入QUESTDB 我正在与ILP Python客户端经历奇怪的行为。我的数据的一部分没有出于没有明显的原因而被写入数据库。以下相关代码： def send_data（QuestDB：c_questdb，

def send_data(questdb: c_questdb, table_name: str, timestamp_column_name: str, data: pd.DataFrame) -> None: """Write dataframe to QuestDB table.""" conf = ( f"tcp::addr={questdb['host']}:{questdb['ilp_port']};" f"username={questdb['ilp_json_web_key_kid']};" f"token={questdb['ilp_json_web_key_d']};" f"token_x={questdb['ilp_json_web_key_x']};" f"token_y={questdb['ilp_json_web_key_y']};" ) with Sender.from_conf(conf) as sender: sender.dataframe(data, table_name=table_name, at=timestamp_column_name) def main(questdb: c_questdb, start_date: str, end_date: str): ... try: # Write data to QuestDB with error handling print("Writing raw weather data to database...") print(all_dfs) with ThreadPoolExecutor() as executor: futures = [] for df in all_dfs: future = executor.submit(send_data, questdb, "weather_raw_data", "DATE", df) futures.append(future) for future in futures: try: future.result() except Exception as e: print(f"Error writing raw data: {str(e)}") print("Writing DJU data to database...") with ThreadPoolExecutor() as executor: futures = [] for df in all_dju_dfs: future = executor.submit(send_data, questdb, "weather_dju", "date", df) futures.append(future) for future in futures: try: future.result() except Exception as e: print(f"Error writing DJU data: {str(e)}") print("All data processed successfully!") except requests.exceptions.HTTPError as e: print(f"API Error: {str(e)}") except ValueError as e: print(f"Date Error: {str(e)}")

QuestDBEnterprise和CARoots

我们试图通过HTTPS ILP连接到QUESTDB，并且该证书不接受。 我已经对此进行了一些研究，问题似乎是以下内容：QuestDB-RS板条箱依赖于ureq for H ...

kafka连接和QuestDB与ProtoBuf

CREATE TABLE IF NOT EXISTS 'transactions' ( timestamp TIMESTAMP, merchant SYMBOL capacity 5000 CACHE, category SYMBOL capacity 256 CACHE, amt DOUBLE, gender SYMBOL capacity 256 CACHE, city SYMBOL capacity 2000 CACHE, state SYMBOL capacity 256 CACHE, first VARCHAR, last VARCHAR, street VARCHAR, job VARCHAR, trans_num VARCHAR, cc_num LONG, zip LONG, city_pop LONG, dob LONG, lat DOUBLE, lon DOUBLE, merch_lat DOUBLE, merch_long DOUBLE ) timestamp (timestamp) PARTITION BY DAY WAL DEDUP UPSERT KEYS(timestamp, trans_num);

我正在尝试在QuestDB（Trades.parquet）内使用内置的镶木式演示文件，以查看其工作原理，但是我被困在无法使用

。 我可以做到这一点

我正在使用Apache气流将旧分区转换为木木木，并使用后射流器将其分离。

这是我现在的相关代码：

用dagster

执行Cron

我有这个表

Scenario：

如何使用node.js

elapsedtime

如何正确使用Sklearn

中使用了

R ggplot2 - 绘制交替 Y 轴

StackOverflow 社区您好， R ggplot2 中有没有一种方法，使用 facet_grid() 函数来获取备用 Y 轴，如下例所示： （具有交替 Y 的多个时间序列图的示例...

如何解读盛宴中的seasonal_trough：feat_stl

我正在寻找有关如何解释 feat_stl 为我的时间序列生成的seasonal_trough_year 特征的指导。我的理解是输出将是一个映射到 g 的整数...

来自 statsmodel.tsa 的 SVAR：if len(A_guess) != n_masked_a: TypeError: 'int' 类型的对象没有 len()

我正在使用以下代码进行 SVAR 估计，但它不断崩溃，总是出现相同类型的错误： len(A_guess) != n_masked_a: TypeError: 类型“int”的对象没有 len()。 任何人都可以...

如何使用 Neural Prophet（新版 Prophet）设置预测上限和下限

使用 NeuralProphet 包进行财务预测，我尝试为我的预测设置最小值（下限）和最大值（上限），例如不要预测负值，也不要预测得太晚...

Apache Flink 的自定义 Prometheus 接收器？

我有一个由Apache Flink处理的时间序列日志，我想绘制grafana的数据，首先将其导出到Prometheus。 java中有没有任何例子或方法可以做到这一点？像令状之类的东西...