问使用logstash jdbc插件在Elasticsearch中添加标签

EN

假设我们有两张桌子

1)客户(CustID，名称)

2)购买(Cust_ID、Purchase_ID)

在(1)和(2)之间存在一对多(1:n)关系。

现在使用logstash，我想将这些数据从sql插入到elasticsearch中。问题是，如果我连接两个表，那么它将为单个客户插入多行/json记录。我希望插入如下数据。

{
Cust_ID : 101,
Purchase_ID : [ 1001, 2003, 20006]
}

但它来的时候

{
Cust_ID : 101,
Purchase_ID : 1001
},
{
Cust_ID : 101,
Purchase_ID : 2003
}

我发现链接https://www.elastic.co/guide/en/elasticsearch/reference/current/array.html很有用。但这并不能解决我的问题。