【问题标题】:cannot delete dynamoDB record containing special characters无法删除包含特殊字符的 dynamoDB 记录
【发布时间】:2017-01-20 05:12:26
【问题描述】:

我有一些无法删除的 dynamoDB 记录,我注意到那些有问题的记录都包含特殊字符。我写了一小段测试代码,并且能够重复这个问题:

require 'aws-sdk-core'
require 'aws-record'

class Task
    include Aws::Record  
    set_table_name "blah"

    string_attr :customer_id, hash_key: true
    string_attr :item, range_key: true
    string_attr :operation, default_value: '+'
    string_attr :device, default_value: 'office-pc'
    string_attr :time, default_value: "00" + Time.now.to_i.to_s
    string_attr :quantity, default_value: '1'
end

Aws.config.update(
    {
        region: 'us-west-2',
        credentials: Aws::Credentials.new(
            'foo', 
            'bar'
        ),
        ssl_verify_peer: false
    }
)

#insert two rows
task1 = Task.new(customer_id: "a", item: "\u2713")
task1.save()
task2 = Task.new(customer_id: "a", item: "check")
task2.save()

#query and delete both
resp = Task.query({
    key_conditions: {
        "customer_id" => {
            attribute_value_list: ["a"], 
            comparison_operator: "EQ", 
        }
    }
})
resp.each do 
    |task|
    puts task.item
    task.delete!
end

#query again, to see what's left
resp = Task.query({
    key_conditions: {
        "customer_id" => {
            attribute_value_list: ["a"], 
            comparison_operator: "EQ", 
        }
    }
})
resp.each do 
    |task|
    puts task.item
end

如下是输出,如您所见,前两行显示插入的内容,最后一行显示 \u2713 即使在删除后仍然存在。

check
Ô£ô
Ô£ô

gem 版本:aws-sdk-core:2.6.49,aws-sdk-resources:2.6.49,aws-record:1.0.3。它们都是最新版本。 ruby 在 Windows 上是 2.3.1。

【问题讨论】:

  • 会有什么反应?
  • 你能检查从控制台删除吗?
  • 是的,我只是说如果你能够从控制台删除,那么可能是代码或sdk有问题

标签: ruby utf-8 amazon-dynamodb special-characters


【解决方案1】:

问题存在于 sdk gem 中:aws-sdk-core-2.7.0(发布 OP 时是最新的 2.6.49,现在是最新的 2.7.0)。只需在 lib\aws-sdk-core\json\handler.rb 中进行一行更改即可轻松修复。

以下是变化:

def parse_body(context)
    if simple_json?(context)
        Json.load(context.http_response.body_contents)
    else
        rules = context.operation.output
        json = context.http_response.body_contents.bytes.pack('c*').force_encoding('utf-8')
        #below line is the original code
        #json = context.http_response.body_contents
        Parser.new(rules).parse(json == '' ? '{}' : json)
    end
end

【讨论】:

    最近更新 更多