Skip to main content

No project description provided

Project description

Datashack

What is this?

Create AWS Kinesis+Glue pipeline with Python, Javascript, Golang, Java. (currently Python only)

For example:

from datashack_sdk_py import StreamingTable, Column

db = Database("db1", "tables-bucket")

UserEvents = StreamingTable("users", "db1")

UserEvents['id'] = Column('string')
UserEvents['age'] = Column('int')
UserEvents['name'] = Column('string')
UserEvents['ts'] = Column('timestamp')

run datashack plan/apply to see the actual changes or actually applying them to your AWS account.

creates this pipeline:

Tux, the Linux mascot

  • Provision Kinesis+Spark+Glue+Iam
  • Automate schema evolution
  • Tests

Pre-requisites

To work with this project, you will need to have the following software installed on your machine:

Getting Started

run in your terminal

pip install datashack-sdk --upgrade
git clone https://github.com/datashack-dev/datashack-sdk-examples
datashack plan ./datashack-sdk-examples/py_my_app/models

Roadmap

  • Additional AWS services
  • Additional data sources and sinks, such as Apache Kafka or Elasticsearch
  • 3rd Party sources - Google Analytics, Salesforce ...
  • Spark based transformation and processing capabilities
  • Integration with CICD workflows
  • Integration with runtime applications
  • Testing
  • Automatic documentation generation
  • More languages support for Datashack SDK: Go, Java, Yaml

Stay tuned

We are working on a fully funcional beta with many more features. Join here so we can ping you

https://www.datashack.dev/stay-in-touch

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

datashack_sdk-0.0.27.tar.gz (30.1 kB view hashes)

Uploaded Source

Supported by

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