百凌离线指标请求计算Kafka消息格式
<p><strong>简要描述：</strong> </p>
<ul>
<li>百凌离线指标请求计算Kafka消息格式</li>
</ul>
<p><strong>Topic：</strong> </p>
<ul>
<li>
<p><code>indicator_calc_req</code></p>
<p><strong>消息体</strong></p>
</li>
</ul>
<pre><code>{
"indicatorId": "2720",
"indicatorName": "白领贷my钱包-最近一笔已结清借款的总逾期天数",
"calcSql": "select '2720' as indicator_id,concat('my_wallet','_',main_attr) as main_attr,rst as res_val,main_attr as user_id,'my_wallet' as product_code from ( select main_attr, cast(max( calc_field ) as string) as rst from (select * from (select consumer_no as main_attr, overdue_day as calc_field, row_number() over (partition by consumer_no order by gmt_repay DESC) as rn from my_wallet.lsd_stage_borrow where 1=1 and ((status = 1 ) ) ) a ) b where rn >= 1 and rn <= 1 group by main_attr ) tmp_t",
"indicatorAlias": "INDICATOR_2720",
"current":1,
"total":28,
"msgId":"704149ae7ef543ee8eb7fee50a403f68",
"batchId":"704149ae7ef543ee8eb7fee50a403f69",
"version":"20190730104339"
}</code></pre>
<p><strong>消息体说明</strong> </p>
<table>
<thead>
<tr>
<th style="text-align: left;">参数名</th>
<th style="text-align: left;">类型</th>
<th>说明</th>
</tr>
</thead>
<tbody>
<tr>
<td style="text-align: left;">calcSql</td>
<td style="text-align: left;">String</td>
<td>请求计算的Hive sql</td>
</tr>
<tr>
<td style="text-align: left;">indicatorId</td>
<td style="text-align: left;">String</td>
<td>指标id</td>
</tr>
<tr>
<td style="text-align: left;">indicatorName</td>
<td style="text-align: left;">String</td>
<td>指标名称</td>
</tr>
<tr>
<td style="text-align: left;">indicatorAlias</td>
<td style="text-align: left;">String</td>
<td>指标别名</td>
</tr>
<tr>
<td style="text-align: left;">current</td>
<td style="text-align: left;">Integer</td>
<td>当前第几条</td>
</tr>
<tr>
<td style="text-align: left;">total</td>
<td style="text-align: left;">Integer</td>
<td>总共多少条</td>
</tr>
<tr>
<td style="text-align: left;">msgId</td>
<td style="text-align: left;">String</td>
<td>唯一id</td>
</tr>
<tr>
<td style="text-align: left;">batchId</td>
<td style="text-align: left;">String</td>
<td>批次id，一批指标唯一标识</td>
</tr>
<tr>
<td style="text-align: left;">version</td>
<td style="text-align: left;">String</td>
<td>版本号</td>
</tr>
</tbody>
</table>
<p><strong>calcSql select字段说明</strong> </p>
<table>
<thead>
<tr>
<th style="text-align: left;">参数名</th>
<th style="text-align: left;">类型</th>
<th>说明</th>
</tr>
</thead>
<tbody>
<tr>
<td style="text-align: left;">indicator_id</td>
<td style="text-align: left;">String</td>
<td>指标id</td>
</tr>
<tr>
<td style="text-align: left;">user_id</td>
<td style="text-align: left;">String</td>
<td>用户id</td>
</tr>
<tr>
<td style="text-align: left;">product_code</td>
<td style="text-align: left;">String</td>
<td>产品code</td>
</tr>
<tr>
<td style="text-align: left;">main_attr</td>
<td style="text-align: left;">String</td>
<td>主属性</td>
</tr>
<tr>
<td style="text-align: left;">res_val</td>
<td style="text-align: left;">String</td>
<td>指标结果</td>
</tr>
</tbody>
</table>
<p>欢迎使用ShowDoc！</p>