# Streamline Subgraph Pipeline Creation With DataStreams

**Published by:** [0xEvan](https://paragraph.com/@0xevan/)
**Published on:** 2023-01-16
**URL:** https://paragraph.com/@0xevan/streamline-subgraph-pipeline-creation-with-datastreams

## Content

DataStreams a Subgraph query utility package that allows users to execute complex Subgraph queries. It provides extended functionality on top of The Graph data access python package Subgrounds. The main benefit is that now anyone can query Subgraph data, save it to their local storage as csv files, and perform data analytics immediately. DataStreams creates a reproducible data pipeline creation process in a transparent, lightweight manner. No database needed! The main package in DataStreams is the Streamer class. Streamer streamlines the Subgraph query process in Python, exposing key information such as the queryable Subgraph schemas and filter clauses. In v1.0.0, functionality includes: DRY Subgraph Query Code - reuse code to reduce complexity of Subgraph queries Parallelized Subgraph Queries - Leverage the standard Python package concurrent to unlock concurrency at the Subgraph query level Example #1 - Access Historical Chainlink Node Data Query the Chainlink Subgraph node for multiple token prices over a customized ranged period. Example notebook found here Example #2 - Parallelized Multi Schema Query Query the Cowswap Subgraph node for four specific schemas with parallelization support. Example notebook found here

## Publication Information

- [0xEvan](https://paragraph.com/@0xevan/): Publication homepage
- [All Posts](https://paragraph.com/@0xevan/): More posts from this publication
- [RSS Feed](https://api.paragraph.com/blogs/rss/@0xevan): Subscribe to updates