Sparta spanner library
Project description
sparta-spanner
Sparta Google Spanner library.
Usage
import os
import sparta.spanner
from sparta.spanner.utils import zip_results
project_id = os.getenv("PROJECT_ID")
instance_id = os.getenv("INSTANCE_ID")
database_id = os.getenv("DATABASE_ID")
db_service = sparta.spanner.DBService(
project_id=project_id,
instance_id=instance_id,
database_id=database_id,
pool_size=5,
session_request_timeout=2,
)
# Blocking
results = zip_results(db_service.execute_sql("SELECT 1 as my_field"))
assert results is not None
assert len(results) == 1
assert results[0] == {"my_field": 1}
# Non-Blocking
def task(snapshot):
result1 = zip_results(snapshot.execute_sql("SELECT 1 as my_field"))
result2 = zip_results(snapshot.execute_sql("SELECT 2 as my_field"))
return result1 + result2
results = await db_service.run_in_snapshot(task, multi_use=True)
assert results is not None
assert len(results) == 2
assert results[0] == {"my_field": 1}
assert results[1] == {"my_field": 2}
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Close
Hashes for sparta_spanner-0.2.0rc2-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | ee2ddbf0daa4c41a702e247a45a6edcc394b7e2b66901b1fb8b11bc788d336a7 |
|
MD5 | 61d7a53dc94dc15607da4e542546bf11 |
|
BLAKE2b-256 | 0a39a9952440a39d64e741707a18d349c4712ea972b4307d43f4f97d35c00c26 |