"आर" प्रोग्रामिंग भाषा के लिए AWS डायनेमोड समर्थन

Question

क्या कोई भी प्रोग्रामिंग भाषा का उपयोग करके अमेज़ॅन डायनेमोड में सफलतापूर्वक CRUD रिकॉर्ड करने में सक्षम है? मैं भाषा बाइंडिंग के इस संदर्भ समर्थित पाया:

http://aws.typepad.com/aws/2012/04/amazon-dynamodb-libraries-mappers-and-mock-implementations-galore.html

ओह, कोई आर हम एक बड़े पैमाने पर डेटा का उपयोग कर परियोजना के लिए dynamodb विचार कर रहे हैं, लेकिन हमारी मुख्य विश्लेषक आर में सबसे ज्यादा आरामदायक है, इसलिए हम तलाश रहे हैं हमारे विकल्प।

Answer 1

इस के लिए कई दृष्टिकोण हैं ... मेरे दो जोड़ते हैं: हाइव और स्ट्रीमिंग के साथ

1- ईएमआर।

हाइव DynamoDB क्वेरी करने के लिए इस्तेमाल किया जाएगा और उस Haddop स्ट्रीमिंग के लिए एक इनपुट के रूप में इस्तेमाल किया जा सकता है, कि किसी भी भाषा कि पढ़ सकते हैं और मानक आईओ से लिखना, आर

सहित बेशक

कि होगा सकता है के साथ इस्तेमाल किया जा सकता अपने सामान्य आर कार्यक्रम और पर्यावरण से बहुत अलग हो, लेकिन यह "बड़े डेटा" उपकरण का लाभ उठाएगा।

2- JVM में आर-ish

आप JVM के लिए एक अनुसंधान दुभाषिया (जैसे Renjin रूप में) या JVM में एक इसी तरह की भाषा का उपयोग करते हैं, तो आप एडब्ल्यूएस जावा SDK और DynamoDB का उपयोग करने में सक्षम होगा पुस्तकालय सीधे, और यह डेवलपर के लिए अधिक परिचित हो सकता है, लेकिन आप अपने डेटा के "bigness" को संभालने के लिए जिम्मेदार होंगे।

Answer 2

डायनेमो डीबी से डेटा में पढ़ने के लिए मैं जो उपयोग कर रहा हूं उसका एक सरलीकृत संस्करण यहां है। यह इस तथ्य पर निर्भर करता है कि आर और पायथन डेटा का आदान-प्रदान कर सकते हैं, और पाइथन में boto नामक लाइब्रेरी को डेटा प्राप्त करना वास्तव में आसान बनाता है DynamoDB। अगर यह सब एक आर पैकेज था, तो यह साफ होगा, लेकिन मैं 25 जीबी मुफ्त स्टोरेज को अमेज़ॅन से प्राप्त कर सकता हूं।

import boto3 
import time 

dynamodb = boto3.resource('dynamodb', 
          aws_access_key_id='<GET ME FROM AWS>', 
          aws_secret_access_key='<ALSO GET ME FROM AWS CONSOLE>', 
          region_name='us-east-1') 

table = dynamodb.Table('comment') ###Your table name in DynamoDB here 

response = table.scan() 
data = response['Items'] 

while 'LastEvaluatedKey' in response: 
    response = table.scan(ExclusiveStartKey=response['LastEvaluatedKey']) 
    data.extend(response['Items']) 

फिर आर में आप यह करते हैं:

सबसे पहले, आप ऐसा नाम query_dynamo.py की तरह एक अजगर स्क्रिप्ट की जरूरत है। यदि आप विंडोज़ पर यह कोशिश कर रहे हैं, तो आप इसके बजाय rPython-win आज़मा सकते हैं। मैंने यह सब उबंटू लिनक्स 16.04 एलटीएस पर किया था।

library(rPython) 


python.load("query_dynamo.py") 
temp = as.data.frame(python.get('data')) 
df = as.data.frame(t(temp)) 
rm(temp) 

अब आपके पास डाइनेमो डीबी में जो कुछ भी रखा गया है, उसके साथ "डीएफ" नामक डेटाफ्रेम होगा।