2016-01-19 2 views
7

Кажется, я не могу получить поддержку потока, работающую в локальном режиме dino local, они поддерживаются? Единственный признак я мог бы найти, что они, является самой последней пули в http://docs.aws.amazon.com/amazondynamodb/latest/developerguide/Tools.DynamoDBLocal.html#Tools.DynamoDBLocal.DifferencesПоддержка потока для локального dynamodb?

С dynamodb локальным, оказывается, что StreamSpecification игнорируется, так что нет LatestStreamArn при вызове CreateTable или describeTable

Следующий код возвращает LatestStreamArn с управляемым сервисом dynamodb но не dynamodb местные:

ddb.createTable({ 
    TableName: 'streaming_test', 

    AttributeDefinitions: [ 
    { AttributeName: 'id', AttributeType: 'S' } 
    ], 

    KeySchema: [ 
    { AttributeName: 'id', KeyType: 'HASH' } 
    ], 

    ProvisionedThroughput: { 
    ReadCapacityUnits: 5, 
    WriteCapacityUnits: 5 
    }, 

    StreamSpecification: { 
    StreamEnabled: true, 
    StreamViewType: 'NEW_AND_OLD_IMAGES' 
    } 
}, function (err, data) { 
    if (err) { 
    console.log(err, err.stack) 
    } else { 
    // data.TableDescription.StreamSpecification and 
    // data.TableDescription.LatestStreamArn are undefined 
    // for dynamodb local 
    console.log(data) 
    } 
}) 

ответ

5

Я не в состоянии воспроизвести проблему. Шаги я взял:

  1. Скачать DynamoDB Local от here
  2. Начало DynamoDB местного с java -Djava.library.path=./DynamoDBLocal_lib -jar DynamoDBLocal.jar -inMemory -sharedDb
  3. Перейдите к http://localhost:8000/shell/
  4. Вставьте код ниже и нажмите на кнопку воспроизведения. Единственное отличие между тем, что я написал, и вашим кодом выше, это то, что я заменил ddb на dynamodb.

Когда я это сделал, я получил непустой и непустой последнийStreamArn из arn:aws:dynamodb:ddblocal:000000000000:table/streaming_test/stream/2017-02-12T08:39:03.722.

dynamodb.createTable({ 
    TableName: 'streaming_test', 

    AttributeDefinitions: [ 
    { AttributeName: 'id', AttributeType: 'S' } 
    ], 

    KeySchema: [ 
    { AttributeName: 'id', KeyType: 'HASH' } 
    ], 

    ProvisionedThroughput: { 
    ReadCapacityUnits: 5, 
    WriteCapacityUnits: 5 
    }, 

    StreamSpecification: { 
    StreamEnabled: true, 
    StreamViewType: 'NEW_AND_OLD_IMAGES' 
    } 
}, function (err, data) { 
    if (err) { 
    console.log(err, err.stack) 
    } else { 
    // data.TableDescription.StreamSpecification and 
    // data.TableDescription.LatestStreamArn are undefined 
    // for dynamodb local 
    console.log(data) 
    } 
}) 
Смежные вопросы