我正在尝试将csv文件的数据摄取到mysql db中。我的csv文件中有一个名为“measurementtime”的字段，值为2018-06-27 11:14.50。我的流将该字段作为字符串，因此putsql给出错误。我使用与此模板相同的模板，但不使用inferavro处理器，因为我已经有了预定义的模式。这是网站链接
如何将datetime字段作为正确的数据类型而不是字符串传递到mysql db中。我应该更改什么设置？
谢谢您
我正在尝试将csv文件的数据摄取到mysql db中。我的csv文件中有一个名为“measurementtime”的字段，值为2018-06-27 11:14.50。我的流将该字段作为字符串，因此putsql给出错误。我使用与此模板相同的模板，但不使用inferavro处理器，因为我已经有了预定义的模式。这是网站链接
如何将datetime字段作为正确的数据类型而不是字符串传递到mysql db中。我应该更改什么设置？
谢谢您
1条答案
按热度按时间brvekthn1#
与
PutDatabaseRecord您可以避免所有这些转换链和过度工程。流程如下：您需要配置
PutDatabaseRecord与RecordReader属性配置为CSVReader和配置CSVReader并设置Schema Registry至AvroSchemaRegistry并提供有效的模式。您可以在这里找到样本流的模板。