@@ -0,0 +1,1190 @@
+import aerospike%0A%0Aclass AerospikeReader:%0A    def __init__(self, *args, **kwargs):%0A        if 'host' in kwargs:%0A            self.host = kwargs%5B'host'%5D%0A        else:%0A            print 'missing host argument, using 127.0.0.1'%0A            self.host = '127.0.0.1'%0A        if 'port' in kwargs:%0A            self.port = kwargs%5B'port'%5D%0A        else:%0A            print 'missing port argument, using 3000'%0A            self.port = 3000%0A        if 'namespace' in kwargs:%0A            self.namespace = kwargs%5B'namespace'%5D%0A        else:%0A            print 'missing namespace argument, using data'%0A            self.namespace = 'data'%0A        if 'set' in kwargs:%0A            self.set = kwargs%5B'set'%5D%0A        else:%0A            print 'missing set argument, using DataTable'%0A            self.set = 'DataTable'%0A%0A    def read(self, *args, **kwargs):%0A        config = %7B'hosts': %5B (self.host, self.port) %5D%7D%0A        client = aerospike.client(config).connect()%0A        %0A        list_of_dicts = %5B%5D%0A        scan = client.scan(self.namespace, self.set)%0A        def append_result((key, metadata, record)):%0A            list_of_dicts.append(record)%0A        scan.foreach(append_result)%0A        %0A        return list_of_dicts%0A%0A

implement aerospike