kvh/snapflow-crunchbase

Snapflow module for Crunchbase

Crunchbase module for the snapflow framework.

Install

pip install snapflow-bigcommerce or poetry add snapflow-bigcommerce

Example

from __future__ import annotations

from snapflow import Environment, graph_from_yaml, run
import snapflow_crunchbase as crunchbase

g = graph_from_yaml("""
nodes:
  - key: import_orders
    snap: crunchbase.import_people
    params:
      api_key: <API_KEY>
      store_id: <STORE_ID>
      from_date: 2020-01-01
      to_date: 2021-04-30
""")

env = Environment(
    modules=[crunchbase, ],
)
run(g, env=env)

# Get the final output block
with env.md_api.begin():
    datablock = env.get_latest_output("import_bulk", g)