Metadata-Version: 2.0
Name: gcloud-rest
Version: 1.5.0
Summary: RESTful Python Client for Google Cloud
Home-page: https://github.com/talkiq/gcloud-rest
Author: TalkIQ
Author-email: engineering@talkiq.com
License: MIT License
Description-Content-Type: UNKNOWN
Platform: Posix; MacOS X; Windows
Classifier: Development Status :: 4 - Beta
Classifier: Intended Audience :: Developers
Classifier: License :: OSI Approved :: MIT License
Classifier: Operating System :: OS Independent
Classifier: Programming Language :: Python :: 2
Classifier: Programming Language :: Python :: 2.7
Classifier: Programming Language :: Python :: 3
Classifier: Programming Language :: Python :: 3.4
Classifier: Programming Language :: Python :: 3.5
Classifier: Programming Language :: Python :: 3.6
Classifier: Topic :: Internet
Requires-Dist: pyjwt (<2.0.0,>=1.5.3)
Requires-Dist: requests[security] (<3.0.0,>=2.0.0)

RESTful Google Cloud Client Library for Python
==============================================

This project is a collection of Google Cloud client libraries for the REST-only
APIs; its *raison d'etre* is to implement a simple `CloudTasks API`_ as well as
a more abstract TaskManager.

|pypi| |circleci| |coverage| |pythons|

Installation
------------

.. code-block:: console

    $ pip install --upgrade gcloud-rest

Usage
-----

This project currently exposes interfaces to ``CloudTasks``, ``KMS``, and
``Storage``.

Storage (see `bucket.py`_):

.. code-block:: python

    from gcloud.rest.storage import Bucket

    bk = Bucket('my-project', 'bucket-name')

    # list all objects
    objects_in_bucket = bk.list_objects()
    # list objects with prefix
    objects_in_bucket = bk.list_objects(prefix='in/subdir/')

    object = bk.download('object-name')
    object_contents = bk.download_as_string('object-name')

KMS (see `client.py`_):

.. code-block:: python

    from gcloud.rest.kms import KMS
    from gcloud.rest.core import encode

    kms = KMS('my-project', 'my-keyring', 'my-key-name')

    # encrypt
    plaintext = 'the-best-animal-is-the-aardvark'
    ciphertext = kms.encrypt(encode(plaintext))

    # decrypt
    assert kms.decode(encode(ciphertext)) == plaintext

TaskQueue (for ``CloudTasks``, see `queue.py`_):

.. code-block:: python

    from gcloud.rest.core import decode
    from gcloud.rest.core import encode
    from gcloud.rest.taskqueue import TaskQueue

    tq = TaskQueue('my-project', 'taskqueue-name')

    # create a task
    payload = 'aardvarks-are-awesome'
    tq.insert(encode(payload))

    # list and get tasks
    tasks = tq.list()
    random_task = tasks.get('tasks')[42]
    random_task_body = tq.get(random_task['name'])

    # lease, renew, and ack/cancel/delete tasks
    task_leases = tq.lease(num_tasks=3)
    tasks = task_lease.get('tasks')
    # assert len(tasks) <= 3

    for task in tasks:
        payload = decode(task['pullMessage']['payload']).decode()

        # you'll need to renew the task if you take longer than
        # task['scheduleTime'] to process it
        tq.renew(task)

        # do something with payload

        if success:
            tq.ack(task)
        elif temporary_failure:
            tq.cancel(task)
        elif permanent_failure:
            tq.delete(task['name'])

TaskManager (for ``CloudTasks``, see `manager.py`_):

.. code-block:: python

    from gcloud.rest.taskqueue import FailFastError
    from gcloud.rest.taskqueue import TaskManager

    def worker_method(payloads):
        for task in payloads:
            # do something with the task

            if success:
                yield 'anything'
            elif temporary_failure:
                yield Exception('insert message here')
            elif permanent_failure:
                yeild FailFastError('insert message here')

    tm = TaskManager('my-project', 'taskqueue-name', worker_method)
    tm.find_tasks_forever()

.. _bucket.py: https://github.com/talkiq/gcloud-rest/blob/master/gcloud/rest/storage/bucket.py
.. _client.py: https://github.com/talkiq/gcloud-rest/blob/master/gcloud/rest/kms/client.py
.. _manager.py: https://github.com/talkiq/gcloud-rest/blob/master/gcloud/rest/taskqueue/manager.py
.. _queue.py: https://github.com/talkiq/gcloud-rest/blob/master/gcloud/rest/taskqueue/queue.py
.. _CloudTasks API: https://cloud.google.com/cloud-tasks/docs/reference/rest/v2beta2/projects.locations.queues.tasks

.. |pypi| image:: https://img.shields.io/pypi/v/gcloud-rest.svg?style=flat-square
    :alt: Latest PyPI Version
    :target: https://pypi.org/project/gcloud-rest/

.. |circleci| image:: https://img.shields.io/circleci/project/github/talkiq/gcloud-rest/master.svg?style=flat-square
    :alt: CircleCI Test Status
    :target: https://circleci.com/gh/talkiq/gcloud-rest/tree/master

.. |coverage| image:: https://img.shields.io/codecov/c/github/talkiq/gcloud-rest/master.svg?style=flat-square
    :alt: Code Coverage
    :target: https://codecov.io/gh/talkiq/gcloud-rest

.. |pythons| image:: https://img.shields.io/pypi/pyversions/gcloud-rest.svg?style=flat-square
    :alt: Python Version Support
    :target: https://pypi.org/project/gcloud-rest/


