下記の日程にて、cloudpackなかのひとが| 日時 | イベント概要 |
| 2月10日（金） | イベント名：第1回「Jaws-UG-Kumamoto」セミナー（Amazonクラウドセミナー） 会場：熊本県熊本市二の丸1-14 桜の馬場 城彩苑 （多目的交流施設） 発表者：@kaz_goto「VPCについて」 |
| 2月18日（土） | イベント名：Japan AWS User Group (JAWS-UG) - Osaka勉強会 第5回 会場：大阪市中央区大手前1-2-15 テレビ大阪 西館１F 発表者： @kaz_goto「VPCについて」 @suz_lab「クラウドデザインパターン」 |
mysql-connector-java-x.x.xx-bin.jar上記を下記のディレクトリにコピーします。
/usr/java再度にCLASSPATHの設定を行います。
CLASSPATH=$CLASSPATH:/usr/java/mysql-connector-java-x.x.xx-bin.jar export CLASSPATH追加後、下記のコマンドで反映させます。
source .bash_profile以上でJavaからMySQＬに接続できます
$ddb = new AmazonDynamoDB( array( 'key' => 'xxxxxxxxxxxxxxx', 'secret' => 'yyyyyyyyyyyyyyyyyyyyyyyyyyyyy', 'default_cache_config' => '/tmp/cache'));
//book
$books = array(
array('1', '978-4274066306', 'Joel on Software'),
array('2', '978-0321413093', 'Implementation Patterns'),
array('3', '978-1244865723', 'Agile Software Development'),
);
for($i=0; $iput_item(array(
'TableName' => 'book',
'Item' => array(
'id' => array(AmazonDynamoDB::TYPE_NUMBER => (string)$books[$i][0]),
'isbn' => array(AmazonDynamoDB::TYPE_STRING => (string)$books[$i][1]),
'name' => array(AmazonDynamoDB::TYPE_STRING => (string)$books[$i][2]),
)
));
}
//comment
$comments = array(
array('1', strtotime('-10 days'), 'memorycraft', 'i like this'),
array('1', strtotime('-7 days'), 'hoge', 'i never like this'),
array('2', strtotime('-9 days'), 'moge', 'this is awesome'),
);
for($i=0; $iput_item(array(
'TableName' => 'comment',
'Item' => array(
'book_id' => array(AmazonDynamoDB::TYPE_NUMBER => (string)$comments[$i][0]),
'posted_at' => array(AmazonDynamoDB::TYPE_NUMBER => (string)$comments[$i][1]),
'username' => array(AmazonDynamoDB::TYPE_STRING => (string)$comments[$i][2]),
'message' => array(AmazonDynamoDB::TYPE_STRING => (string)$comments[$i][3]),
)
));
}
//Hashプライマリキーで完全一致
echo 'get_item (1) ' .
print_r(
$ddb->get_item(
array(
'TableName' => 'book',
'Key' => array('HashKeyElement' => array(AmazonDynamoDB::TYPE_NUMBER => '1')
)
)->body->Item->to_json(),
true
) . "\n";
出力は以下のようになります。
get_item (1) {"id":{"N":"1"},"isbn":{"S":"978-4274066306"},"name":{"S":"Joel on Software"}}
//複合キーで検索
echo 'query ' .
print_r(
$ddb->query(
array('TableName' => 'comment',
'HashKeyValue' => array(AmazonDynamoDB::TYPE_NUMBER => '1'),
'ConsistentRead' => true,
'RangeKeyCondition' => array(
'ComparisonOperator' => AmazonDynamoDB::CONDITION_GREATER_THAN_OR_EQUAL,
'AttributeValueList' => array(array(AmazonDynamoDB::TYPE_NUMBER => (string)strtotime('-8 days')))
)
)
)->body->Items->to_json(),
true
) . "\n";
出力は以下のようになります。
query {"0":{"book_id":{"N":"1"},"message":{"S":"i never like this"},"posted_at":{"N":"1326880572"},"username":{"S":"hoge"}}}
また、キー値以外で検索を行う場合は、scan関数を利用します。
//キー以外で検索
echo 'scan ' .
print_r(
$ddb->scan(
array(
'TableName' => 'comment',
'AttributeToGet' => array('username', 'message'),
'ScanFilter' => array(
'username' => array(
'ComparisonOperator' => AmazonDynamoDB::CONDITION_EQUAL,
'AttributeValueList' => array(
array(AmazonDynamoDB::TYPE_STRING => 'memorycraft')
)
)
)
)
)->body->Items->to_json(),
true
) . "\n";
出力は以下のようになります。
scan {"0":{"book_id":{"N":"1"},"message":{"S":"i like this"},"posted_at":{"N":"1326621372"},"username":{"S":"memorycraft"}}}
//book
$ddb->create_table(array(
'TableName' => 'book',
'KeySchema' => array(
'HashKeyElement' => array(
'AttributeName' => 'id',
'AttributeType' => AmazonDynamoDB::TYPE_NUMBER
)
),
'ProvisionedThroughput' => array(
'ReadCapacityUnits' => 50,
'WriteCapacityUnits' => 10
)
));
//comment
$ddb->create_table(array(
'TableName' => 'comment',
'KeySchema' => array(
'HashKeyElement' => array(
'AttributeName' => 'book_id',
'AttributeType' => AmazonDynamoDB::TYPE_NUMBER
),
'RangeKeyElement' => array(
'AttributeName' => 'posted_at',
'AttributeType' => AmazonDynamoDB::TYPE_NUMBER
)
),
'ProvisionedThroughput' => array(
'ReadCapacityUnits' => 50,
'WriteCapacityUnits' => 10
)
));
この際、テーブルの作成には時間が多少かかるので、テーブルを作成した後に続けてforeach(array('book', 'comment') as $table_name){
$count = 0;
echo $table_name . " : status ";
do {
sleep(1);
$count++;
$res = $ddb->describe_table(array(
'TableName' => $table_name
));
$status = (string)$res->body->Table->TableStatus;
echo ($status === 'ACTIVE' ? $status . "\n" : '.');
}
while ((string) $res->body->Table->TableStatus !== 'ACTIVE');
}
出力は以下のようになります。
book : status ...........................ACTIVE comment : status ACTIVE
foreach(array('book', 'comment') as $table_name){
$ddb->delete_table(
array('TableName' => $table_name)
);
}
Read Capacity：1秒間に読み込みされる回数 × 1つのアイテムの平均サイズ
Write Capacity：1秒間に書き込みされる回数 × 1つのアイテムの平均サイズ
