aerospike_client_connect_write_read_record_quickstart.py

1import aerospike
2import sys
3
4# Configure the client
5config = {
6    'hosts': [('127.0.0.1', 3000)]
7}
8
9# Create a client and connect it to the cluster
10try:
11    client = aerospike.client(config).connect()
12except Exception as e:
13    print("failed to connect to the cluster with", config['hosts'])
14    sys.exit(1)
15
16# Records are addressable via a tuple of (namespace, set, key)
17key = ('test', 'demo', 'foo')
18
19try:
20    # Write a record
21    client.put(key, {
22        'name': 'John Doe',
23        'age': 32
24    })
25except Exception as e:
26    print("error: {0}".format(e))
27
28# Read a record
29(key, metadata, record) = client.get(key)
30print(record)
31
32# Close the connection to the Aerospike cluster
33client.close()