当前位置:  开发笔记 > 前端 > 正文

如何将AWS Kinesis Firehose格式的记录格式化为Redshift?

如何解决《如何将AWSKinesisFirehose格式的记录格式化为Redshift?》经验,为你挑选了1个好方法。



1> Jamie McCrin..:

答案在这里:

http://docs.aws.amazon.com/redshift/latest/dg/copy-parameters-data-format.html

字段必须是管道'|' 默认分开.行应该用新行分隔.

更新的更正代码:

let AWS = require('aws-sdk');
let firehose = new AWS.Firehose();
let params = {
  DeliveryStreamName: 'people',
  // id,name,age
  Records: [{Data: '4ccf6d3a-acdf-11e5-ad54-28cfe91fa8f1|Bob|Smith\n'}]
};
firehose.putRecordBatch(params, (err, result) => {
  console.log(err || result);
});

推荐阅读
TXCWB_523
这个屌丝很懒,什么也没留下!
DevBox开发工具箱 | 专业的在线开发工具网站    京公网安备 11010802040832号  |  京ICP备19059560号-6
Copyright © 1998 - 2020 DevBox.CN. All Rights Reserved devBox.cn 开发工具箱 版权所有