首页 > 解决方案 > DynamoDB Marshal 和 unmarshal golang time.Time as millis since epoch

问题描述

默认情况下,sdk 将值编组time.Time为 RFC3339 字符串。您如何选择以其他方式编组和解组,例如自纪元以来的毫秒?

SDK 提到了 Marshaler 和 Unmarshaler 接口,但没有解释如何使用它们。

标签: amazon-web-servicesgoamazon-dynamodbaws-sdk-go

解决方案


(当我即将发布我的问题时,我通过研究UnixTime工作方式找到了答案)。

要使用自定义 Marshaler 和 Unmarshaler,您可以创建自定义类型。

type MillisTime time.Time

func (e MillisTime) MarshalDynamoDBAttributeValue(av *dynamodb.AttributeValue) error {
    millis := timeAsMillis(time.Time(e))
    millisStr := fmt.Sprintf("%d", millis)
    av.N = &millisStr
    return nil
}

func (e *MillisTime) UnmarshalDynamoDBAttributeValue(av *dynamodb.AttributeValue) error {
    millis, err := strconv.ParseInt(*av.N, 10, 0)
    if err != nil {
        return err
    }
    *e = MillisTime(millisAsTime(millis))
    return nil
}

func timeAsMillis(t time.Time) int64 {
    nanosSinceEpoch := t.UnixNano()
    return (nanosSinceEpoch / 1_000_000_000) + (nanosSinceEpoch % 1_000_000_000)
}

func millisAsTime(millis int64) time.Time {
    seconds := millis / 1_000
    nanos := (millis % 1_000) * 1_000_000
    return time.Unix(seconds, nanos)
}

注意:上面的示例使用 go 1.13 中引入的新数字文字语法。

您可以使用 轻松编组和解组结构MarshalMapUnmarshalMap但缺点是结构类型中的字段必须使用 MillisTime 而不是time.Time. 转换并不容易,但却是可能的。

SDK 定义了一种类型,它将处理自纪元以来 <=> 秒UnixTime之间的编组和解组。time.Time


推荐阅读