Skip to content

Latest commit

 

History

History
35 lines (27 loc) · 710 Bytes

getting-started.md

File metadata and controls

35 lines (27 loc) · 710 Bytes

Getting Started

Initialize

Start initialize local data framework with the init CLI.

deflow init

The output project structure that was auto created from the initialize command:

conf/
 ├─ conn/
 │   ├─ c_conn_01.yml
 │   ╰─ c_conn_02.yml
 ╰─ stream/
     ╰─ s_stream_01/
         ├─ g_group_01.tier.priority/
         │   ├─ p_proces_01.yml
         │   ╰─ p_proces_02.yml
         ├─ g_group_02.tier.priority/
         │   ├─ p_proces_01.yml
         │   ╰─ p_proces_02.yml
         ╰─ s_stream_01.yml

Running Flow

from deflow.flow import Flow

flow = Flow(name="s_stream_name_d").run(mode="N")