当前位置: 首页 > 知识库问答 >
问题:

在knex.stream中传递列名

太叔逸春
2023-03-14

我目前正在使用knex查询我的数据库,并将结果流到S3上上传的CSV文件中。

然而,我正在努力寻找一种方法来传递列名,以便它们构成csv文件的第一行。

下面是我的代码:

const stringifier = Stringify()    
knex.raw('SELECT id, name FROM table LIMIT 20').stream().pipe(stringifier)
                .pipe(gzip)
                .pipe(s3WritableStream);

这只发送每一行。

我应该怎么做才能将每一列的名称作为CSV中的第一行包含呢?

谢谢!

共有1个答案

伏业
2023-03-14

找到了解决办法。 只需在stringify中添加“header”即可:

const stringifier = Stringify({
                header:true
            })
 类似资料:
  • 例如,我的mapper.xml文件中有以下xml片段: 如您所见,with订阅只有一列 我想传递2列给它,因此得到的代码,我们怎么做?

  • 我想计算PySpark数据帧的两列之间的Jaro Winkler距离。Jaro-Winkler距离可通过所有节点上的pyjarowinkler包获得。 pyjarowinkler的工作原理如下: 输出: 我试图编写一个UDF,将两列作为序列传递,并使用lambda函数计算距离。我是这样做的: 我应该能够在上述函数中传递任意两个字符串列。我得到以下输出: 预期产出: 我怀疑这可能是因为不正确。它包含

  • 我有一个包含两列的数据帧,一列是数据,另一列是该数据字段中的字符计数。 我想根据count列中的值更改列数据的值。如何实现这一点?我尝试使用一个udf: 这似乎是失败的,这是正确的做法吗?

  • 问题内容: 这是我程序中的代码片段。我打算做的是在查询中传递列名和参数。 过滤器数组包含列名,参数数组包含参数。计数是用户设置的过滤器数。过滤器和参数数组已经准备就绪,没有问题。我只需要将其传递给查询即可执行。这给我一个错误“ TypeError:函数最多接受2个参数” 问题答案: 您只能使用设置参数,不能使用表或列名称。 您可以使用预定义的查询来构建字典。 这种方法将使您避免从中进行SQL注入。

  • 我在Scala的Spark数据框架中有一列,它是使用 我想将此列传递给UDF,以便进一步处理,以处理此聚合列中的一个索引。 当我将参数传递给我的UDF时: UDF-类型为Seq[Row]:val removeUnstableActivations:UserDefinedFunction=UDF((xyz:java.util.Date,def:Seq[Row]) 我收到错误: 我应该如何传递这些列,

  • 我正在编写一个用户定义的函数,它将接受数据帧中除第一列之外的所有列,并进行求和(或任何其他操作)。现在,数据帧有时可以有3列或4列或更多。会有所不同。 我知道我可以在UDF中硬编码4个列名作为传递,但在这种情况下它会有所不同,所以我想知道如何完成它? 这里有两个示例,第一个示例中我们有两列要添加,第二个示例中有三列要添加。

  • 问题内容: 当您将诸如list,array之类的集合传递给python中的另一个函数时,它是否会复制它,还是只是一个指针? 问题答案: Python按值传递对对象的引用。 Python按值传递对对象的引用(例如Java),Python中的所有对象都是对象。这听起来很简单,但是随后您会注意到某些数据类型似乎表现出按值传递特性,而其他数据类型似乎表现为按引用传递……这是怎么回事? 了解可变和不可变的对

  • 我是PYSPARK/SPARKSQL的初学者,我有一个如下的要求,我有一个如下的配置表(DataFrame:Config),Config:< br > | data frame | col 1 | col 2 | col 3 |:-|:-:|-:|-:|-:| Emp | name 1 | name 2 | Address | Job | Doj | Role | DOB 我已经迭代了上面的数据帧