问题标签 [exasol]

我正在尝试设置 kafka sink 连接器以写入 exasol 数据库。

我已关注https://www.confluent.io/blog/simplest-useful-kafka-connect-data-pipeline-world-thereabouts-part-1/这篇文章。

由于我找不到任何类似的 exasol 接收器连接器类，因此我尝试使用 jar https://github.com/exasol/kafka-connect-jdbc-exasol/tree/master/kafka-connect-exasol/jars [复制了这个$confluent_dir/share/java/kafka-connect-jdbc] 中的 jar 并在下面的配置 json 文件中将其中的 Dialect 类作为连接器类名给出。

我正在尝试使用以下命令加载此连接器：

以类似的方式，我创建了一个 mysql-source 连接器，用于从 mysql 读取数据并且它运​​行良好，我的用例要求使用 sink-connector 将该数据写入 exasol 数据库。

虽然我没有收到任何异常，但 kafka 没有阅读任何消息。

配置此类接收器连接器以写入 exasol 数据库的任何指针或帮助。

我想使用 Scala 连接到 ExaSol 数据库。我可以使用 pyodbc 连接到 Python 中的数据库，但是在尝试使用 Scala 中的 JDBC 驱动程序连接时收到以下错误：

将pyexasol import_from_pandas(df)用于df具有 datetime 列的 DataFrame 时，Exasol (6.2) 会引发错误，因为它无法解析数据框列的 ISO 格式字符串表示。具体来说，Exasol 无法解析“+00:00”最终字符。我目前的解决方法是将所有 pandas 日期时间列转换为字符串列，但这可能会花费大量时间。

TIMESTAMP将 Pandas 数据帧中的日期时间列导入具有列类型的现有 Exasol 表的正确方法是什么？

我正在尝试使用我的 Bitbucket 管道中的 testcontainers 运行集成测试。对于每个测试，我都需要启动一个新的Exasol 图像。但是，这需要以特权模式启动

用于权限管理、UDF 支持以及环境配置和验证

，而这又是 bitbucket 不允许的。

有没有办法在没有特权模式的情况下启动 Exasol 图像？或者有人对不同的解决方案有想法，以便我能够运行我的集成测试？

我正在尝试使用 PyExasol 从 Exasol 中并行获取数据。我在这里关注示例 - https://github.com/badoo/pyexasol/blob/master/examples/14_parallel_export.py

我的代码如下所示：

在最后一条语句中，我收到以下错误并且无法获取任何结果。

似乎返回语句的类型不是'resultSet'而是'rowCount'。关于我做错了什么或为什么语句类型是 ''rowCount' 的任何帮助？

我有一张像

我想像这样

输出中的行数可能会有所不同。

枢轴不能像在 exasol 中那样工作，并且外壳不能工作，因为它是动态的

我有一个带有自动增量主键的 Exasol 表，并希望使用 pyexasol 的 import_from_pandas 填充它。

通过导入 exasol 表，我必须将 RKEY 排除在外，因为 Exasol 会自动递增它。但是将 rkey 留空或根本不在 pandas 中创建 rkey 列对我来说不起作用。

我浏览了 pandas.to_csv 并且在写入 csv 时似乎没有选择省略列。

有人有解决这个问题的方法吗？

我需要替换新行后面没有冒号的所有实例。这是因为冒号表示新记录的开始（一条记录可能跨越多行）。

例如，输入：

产生输出：

代替：

请注意，当前输出替换了第一个非 ':' 字符，而不是新行。有谁知道为什么这不能按预期工作？

提前致谢

是否可以在 exasol 中使用 alter table 在单个查询执行中向表中添加多个列？

例子：

Alter table Employee add column phone_number varchar(256), add column address varchar(256)

我正在尝试在 Alteryx 中创建以下逻辑，并且数据来自 Exasol 数据库。

“Sum_Qty_28_days”列应总结过去 28 天内同一文章的“Qty”列的值。

我的示例数据如下所示：

我想要以下输出：

例如，“article” = 'A' 和 date = ''2019-10-8” 的“Sum_Qty_28_days”值为 8，因为它汇总了与日期相关的“Qty”值（在过去 28 天内出现），即：2019 -09-15 2019-10-05 2019-10-08 “文章” = 'A'。

这可能使用 SQL 窗口函数吗？我尝试了以下代码：

但是，这远远不是我需要的。它总结了同一个月内日期的数量。但是，我需要总结过去 28 天的数量。

提前致谢。