Skip to main content

A Pythonic Interface to DynamoDB (fork with flag to return conflict record)

Project description

https://img.shields.io/pypi/v/pynamodb.svg https://img.shields.io/conda/vn/conda-forge/pynamodb.svg https://github.com/pynamodb/PynamoDB/workflows/Tests/badge.svg https://img.shields.io/coveralls/pynamodb/PynamoDB/master.svg

A Pythonic interface for Amazon’s DynamoDB.

DynamoDB is a great NoSQL service provided by Amazon, but the API is verbose. PynamoDB presents you with a simple, elegant API.

Useful links:

Installation

From PyPi:

$ pip install pynamodb

From GitHub:

$ pip install git+https://github.com/pynamodb/PynamoDB#egg=pynamodb

From conda-forge:

$ conda install -c conda-forge pynamodb

Basic Usage

Create a model that describes your DynamoDB table.

from pynamodb.models import Model
from pynamodb.attributes import UnicodeAttribute

class UserModel(Model):
    """
    A DynamoDB User
    """
    class Meta:
        table_name = "dynamodb-user"
    email = UnicodeAttribute(null=True)
    first_name = UnicodeAttribute(range_key=True)
    last_name = UnicodeAttribute(hash_key=True)

PynamoDB allows you to create the table if needed (it must exist before you can use it!):

UserModel.create_table(read_capacity_units=1, write_capacity_units=1)

Create a new user:

user = UserModel("John", "Denver")
user.email = "djohn@company.org"
user.save()

Now, search your table for all users with a last name of ‘Denver’ and whose first name begins with ‘J’:

for user in UserModel.query("Denver", UserModel.first_name.startswith("J")):
    print(user.first_name)

Examples of ways to query your table with filter conditions:

for user in UserModel.query("Denver", UserModel.email=="djohn@company.org"):
    print(user.first_name)

Retrieve an existing user:

try:
    user = UserModel.get("John", "Denver")
    print(user)
except UserModel.DoesNotExist:
    print("User does not exist")

Upgrade Warning

The behavior of ‘UnicodeSetAttribute’ has changed in backwards-incompatible ways as of the 1.6.0 and 3.0.1 releases of PynamoDB.

See UnicodeSetAttribute upgrade docs for detailed instructions on how to safely perform the upgrade.

Advanced Usage

Want to use indexes? No problem:

from pynamodb.models import Model
from pynamodb.indexes import GlobalSecondaryIndex, AllProjection
from pynamodb.attributes import NumberAttribute, UnicodeAttribute

class ViewIndex(GlobalSecondaryIndex):
    class Meta:
        read_capacity_units = 2
        write_capacity_units = 1
        projection = AllProjection()
    view = NumberAttribute(default=0, hash_key=True)

class TestModel(Model):
    class Meta:
        table_name = "TestModel"
    forum = UnicodeAttribute(hash_key=True)
    thread = UnicodeAttribute(range_key=True)
    view = NumberAttribute(default=0)
    view_index = ViewIndex()

Now query the index for all items with 0 views:

for item in TestModel.view_index.query(0):
    print("Item queried from index: {0}".format(item))

It’s really that simple.

Want to use DynamoDB local? Just add a host name attribute and specify your local server.

from pynamodb.models import Model
from pynamodb.attributes import UnicodeAttribute

class UserModel(Model):
    """
    A DynamoDB User
    """
    class Meta:
        table_name = "dynamodb-user"
        host = "http://localhost:8000"
    email = UnicodeAttribute(null=True)
    first_name = UnicodeAttribute(range_key=True)
    last_name = UnicodeAttribute(hash_key=True)

Want to enable streams on a table? Just add a stream_view_type name attribute and specify the type of data you’d like to stream.

from pynamodb.models import Model
from pynamodb.attributes import UnicodeAttribute
from pynamodb.constants import STREAM_NEW_AND_OLD_IMAGE

class AnimalModel(Model):
    """
    A DynamoDB Animal
    """
    class Meta:
        table_name = "dynamodb-user"
        host = "http://localhost:8000"
        stream_view_type = STREAM_NEW_AND_OLD_IMAGE
    type = UnicodeAttribute(null=True)
    name = UnicodeAttribute(range_key=True)
    id = UnicodeAttribute(hash_key=True)

Features

  • Python >= 3.7 support

  • An ORM-like interface with query and scan filters

  • Compatible with DynamoDB Local

  • Supports the entire DynamoDB API

  • Support for Unicode, Binary, JSON, Number, Set, and UTC Datetime attributes

  • Support for Global and Local Secondary Indexes

  • Provides iterators for working with queries, scans, that are automatically paginated

  • Automatic pagination for bulk operations

  • Complex queries

  • Batch operations with automatic pagination

  • Iterators for working with Query and Scan operations

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

spendo_pynamodb-6.0.2.1.tar.gz (95.4 kB view details)

Uploaded Source

Built Distribution

If you're not sure about the file name format, learn more about wheel file names.

spendo_pynamodb-6.0.2.1-py3-none-any.whl (61.6 kB view details)

Uploaded Python 3

File details

Details for the file spendo_pynamodb-6.0.2.1.tar.gz.

File metadata

  • Download URL: spendo_pynamodb-6.0.2.1.tar.gz
  • Upload date:
  • Size: 95.4 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: twine/6.1.0 CPython/3.11.5

File hashes

Hashes for spendo_pynamodb-6.0.2.1.tar.gz
Algorithm Hash digest
SHA256 0313b56877e857bbc7322f6dcfff9e25b123545ecc45ddd3cb60d434f8f1b80c
MD5 d17b482528b5559d4d8c1a41280b6694
BLAKE2b-256 9512b07410631319441ef1325cba13e37945e688b335f3cc09d96a6d435a425c

See more details on using hashes here.

File details

Details for the file spendo_pynamodb-6.0.2.1-py3-none-any.whl.

File metadata

File hashes

Hashes for spendo_pynamodb-6.0.2.1-py3-none-any.whl
Algorithm Hash digest
SHA256 e35ef16615d312c9402a99fe98c2bf663a436e32d2e7ae395abd55328e4d430d
MD5 6e0ec31bca08570124b388dac490d876
BLAKE2b-256 d6293adfec845ef5bae56be333870da41cb9959a9187287aad472ae1788e905a

See more details on using hashes here.

Supported by

AWS Cloud computing and Security Sponsor Datadog Monitoring Depot Continuous Integration Fastly CDN Google Download Analytics Pingdom Monitoring Sentry Error logging StatusPage Status page