SQLをKVSに変換する
データ直列系ではkvsの方がよいので
図1. このようなフォーマットにする
- Sparkできなシステムに還元する際は、KVSフォーマットを構築する必要がある
select
tuuid,
array_join(array_agg(col), ',')
from
(select tuuid, date_time || ' ' || ip || ' ' || request_uri || ' ' || ipao97_value || ' ' || referer as col from tech_batch.latest_60days)
group by tuuid