본문으로 건너뛰기
버전: In Development

Query Guide

Secondary Index Query​

쿼리를 수행하려면 조회 대상 bin에 Secondary Index가 필요합니다.

Step 1: Create Secondary Index​

import aerospike_py as aerospike

client = aerospike.client({
    "hosts": [("127.0.0.1", 3000)],
    "cluster_name": "docker",
}).connect()

# 정수 인덱스
client.index_integer_create("test", "users", "age", "users_age_idx")

# 문자열 인덱스
client.index_string_create("test", "users", "city", "users_city_idx")

# 지리공간 인덱스
client.index_geo2dsphere_create("test", "locations", "coords", "geo_idx")

Step 2: Insert Data​

for i in range(100):
    client.put(("test", "users", f"user_{i}"), {
        "name": f"User {i}",
        "age": 20 + (i % 40),
        "city": ["Seoul", "Tokyo", "NYC"][i % 3],
    })

Step 3: Query with Predicate​

from aerospike_py import predicates

# 동등 쿼리
query = client.query("test", "users")
query.where(predicates.equals("city", "Seoul"))
records = query.results()

# 범위 쿼리
query = client.query("test", "users")
query.where(predicates.between("age", 25, 35))
records = query.results()

Select Specific Bins​

query = client.query("test", "users")
query.select("name", "age")
query.where(predicates.between("age", 25, 35))
records = query.results()

Iterate with Callback​

query = client.query("test", "users")
query.where(predicates.between("age", 25, 35))

def process(record):
    key, meta, bins = record
    print(f"{bins['name']}: age {bins['age']}")

query.foreach(process)

Early Termination​

count = 0

def limited(record):
    global count
    count += 1
    _, _, bins = record
    print(bins)
    if count >= 5:
        return False  # 반복 중단

query.foreach(limited)

Cleanup Indexes​

client.index_remove("test", "users_age_idx")
client.index_remove("test", "users_city_idx")

Predicate Reference​

함수설명예시
equals(bin, val)동등 조건equals("name", "Alice")
between(bin, min, max)범위 조건 (양 끝 포함)between("age", 20, 30)
contains(bin, idx_type, val)list/map 포함 여부contains("tags", INDEX_TYPE_LIST, "py")
geo_within_geojson_region(bin, geojson)영역 내 포인트아래 참조
geo_within_radius(bin, lat, lng, radius)원형 범위 내 포인트아래 참조
geo_contains_geojson_point(bin, geojson)포인트를 포함하는 영역아래 참조

지리공간 예시​

# 다각형 내의 포인트
region = '{"type":"Polygon","coordinates":[[[126.9,37.5],[126.9,37.6],[127.0,37.6],[127.0,37.5],[126.9,37.5]]]}'
query.where(predicates.geo_within_geojson_region("location", region))

# 반경 내의 포인트 (미터 단위)
query.where(predicates.geo_within_radius("location", 37.5665, 126.978, 5000.0))

# 포인트를 포함하는 영역
point = '{"type":"Point","coordinates":[126.978, 37.5665]}'
query.where(predicates.geo_contains_geojson_point("coverage", point))