Skip to content

Commit ecd51d6

Browse files
committed
add: loader classes adjusted
1 parent a104e04 commit ecd51d6

File tree

6 files changed

+426
-6
lines changed

6 files changed

+426
-6
lines changed

docs/timeseries_shaper/loader/timeseries/timescale_loader.html

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -131,7 +131,7 @@ <h1 class="modulename">
131131
</span><span id="L-55"><a href="#L-55"><span class="linenos">55</span></a> <span class="k">for</span> <span class="n">_</span><span class="p">,</span> <span class="n">row</span> <span class="ow">in</span> <span class="n">chunk</span><span class="o">.</span><span class="n">iterrows</span><span class="p">():</span>
132132
</span><span id="L-56"><a href="#L-56"><span class="linenos">56</span></a> <span class="n">systime</span> <span class="o">=</span> <span class="n">row</span><span class="p">[</span><span class="s1">&#39;systime&#39;</span><span class="p">]</span>
133133
</span><span id="L-57"><a href="#L-57"><span class="linenos">57</span></a> <span class="n">timeslot_dir</span> <span class="o">=</span> <span class="n">Path</span><span class="p">(</span><span class="nb">str</span><span class="p">(</span><span class="n">systime</span><span class="o">.</span><span class="n">year</span><span class="p">),</span> <span class="nb">str</span><span class="p">(</span><span class="n">systime</span><span class="o">.</span><span class="n">month</span><span class="p">)</span><span class="o">.</span><span class="n">zfill</span><span class="p">(</span><span class="mi">2</span><span class="p">),</span> <span class="nb">str</span><span class="p">(</span><span class="n">systime</span><span class="o">.</span><span class="n">day</span><span class="p">)</span><span class="o">.</span><span class="n">zfill</span><span class="p">(</span><span class="mi">2</span><span class="p">),</span> <span class="nb">str</span><span class="p">(</span><span class="n">systime</span><span class="o">.</span><span class="n">hour</span><span class="p">)</span><span class="o">.</span><span class="n">zfill</span><span class="p">(</span><span class="mi">2</span><span class="p">))</span>
134-
</span><span id="L-58"><a href="#L-58"><span class="linenos">58</span></a> <span class="n">output_path</span> <span class="o">=</span> <span class="n">Path</span><span class="p">(</span><span class="n">output_dir</span><span class="p">,</span> <span class="sa">f</span><span class="s2">&quot;</span><span class="si">{</span><span class="n">uuid</span><span class="si">}</span><span class="s2">/</span><span class="si">{</span><span class="n">timeslot_dir</span><span class="si">}</span><span class="s2">&quot;</span><span class="p">)</span>
134+
</span><span id="L-58"><a href="#L-58"><span class="linenos">58</span></a> <span class="n">output_path</span> <span class="o">=</span> <span class="n">Path</span><span class="p">(</span><span class="n">output_dir</span><span class="p">,</span> <span class="n">timeslot_dir</span><span class="p">)</span>
135135
</span><span id="L-59"><a href="#L-59"><span class="linenos">59</span></a> <span class="n">output_path</span><span class="o">.</span><span class="n">mkdir</span><span class="p">(</span><span class="n">parents</span><span class="o">=</span><span class="kc">True</span><span class="p">,</span> <span class="n">exist_ok</span><span class="o">=</span><span class="kc">True</span><span class="p">)</span>
136136
</span><span id="L-60"><a href="#L-60"><span class="linenos">60</span></a> <span class="n">row</span><span class="o">.</span><span class="n">to_frame</span><span class="p">()</span><span class="o">.</span><span class="n">T</span><span class="o">.</span><span class="n">to_parquet</span><span class="p">(</span><span class="n">output_path</span> <span class="o">/</span> <span class="sa">f</span><span class="s2">&quot;</span><span class="si">{</span><span class="n">uuid</span><span class="si">}</span><span class="s2">.parquet&quot;</span><span class="p">,</span> <span class="n">index</span><span class="o">=</span><span class="kc">False</span><span class="p">)</span>
137137
</span><span id="L-61"><a href="#L-61"><span class="linenos">61</span></a>
@@ -209,7 +209,7 @@ <h1 class="modulename">
209209
</span><span id="TimescaleDBDataAccess-56"><a href="#TimescaleDBDataAccess-56"><span class="linenos">56</span></a> <span class="k">for</span> <span class="n">_</span><span class="p">,</span> <span class="n">row</span> <span class="ow">in</span> <span class="n">chunk</span><span class="o">.</span><span class="n">iterrows</span><span class="p">():</span>
210210
</span><span id="TimescaleDBDataAccess-57"><a href="#TimescaleDBDataAccess-57"><span class="linenos">57</span></a> <span class="n">systime</span> <span class="o">=</span> <span class="n">row</span><span class="p">[</span><span class="s1">&#39;systime&#39;</span><span class="p">]</span>
211211
</span><span id="TimescaleDBDataAccess-58"><a href="#TimescaleDBDataAccess-58"><span class="linenos">58</span></a> <span class="n">timeslot_dir</span> <span class="o">=</span> <span class="n">Path</span><span class="p">(</span><span class="nb">str</span><span class="p">(</span><span class="n">systime</span><span class="o">.</span><span class="n">year</span><span class="p">),</span> <span class="nb">str</span><span class="p">(</span><span class="n">systime</span><span class="o">.</span><span class="n">month</span><span class="p">)</span><span class="o">.</span><span class="n">zfill</span><span class="p">(</span><span class="mi">2</span><span class="p">),</span> <span class="nb">str</span><span class="p">(</span><span class="n">systime</span><span class="o">.</span><span class="n">day</span><span class="p">)</span><span class="o">.</span><span class="n">zfill</span><span class="p">(</span><span class="mi">2</span><span class="p">),</span> <span class="nb">str</span><span class="p">(</span><span class="n">systime</span><span class="o">.</span><span class="n">hour</span><span class="p">)</span><span class="o">.</span><span class="n">zfill</span><span class="p">(</span><span class="mi">2</span><span class="p">))</span>
212-
</span><span id="TimescaleDBDataAccess-59"><a href="#TimescaleDBDataAccess-59"><span class="linenos">59</span></a> <span class="n">output_path</span> <span class="o">=</span> <span class="n">Path</span><span class="p">(</span><span class="n">output_dir</span><span class="p">,</span> <span class="sa">f</span><span class="s2">&quot;</span><span class="si">{</span><span class="n">uuid</span><span class="si">}</span><span class="s2">/</span><span class="si">{</span><span class="n">timeslot_dir</span><span class="si">}</span><span class="s2">&quot;</span><span class="p">)</span>
212+
</span><span id="TimescaleDBDataAccess-59"><a href="#TimescaleDBDataAccess-59"><span class="linenos">59</span></a> <span class="n">output_path</span> <span class="o">=</span> <span class="n">Path</span><span class="p">(</span><span class="n">output_dir</span><span class="p">,</span> <span class="n">timeslot_dir</span><span class="p">)</span>
213213
</span><span id="TimescaleDBDataAccess-60"><a href="#TimescaleDBDataAccess-60"><span class="linenos">60</span></a> <span class="n">output_path</span><span class="o">.</span><span class="n">mkdir</span><span class="p">(</span><span class="n">parents</span><span class="o">=</span><span class="kc">True</span><span class="p">,</span> <span class="n">exist_ok</span><span class="o">=</span><span class="kc">True</span><span class="p">)</span>
214214
</span><span id="TimescaleDBDataAccess-61"><a href="#TimescaleDBDataAccess-61"><span class="linenos">61</span></a> <span class="n">row</span><span class="o">.</span><span class="n">to_frame</span><span class="p">()</span><span class="o">.</span><span class="n">T</span><span class="o">.</span><span class="n">to_parquet</span><span class="p">(</span><span class="n">output_path</span> <span class="o">/</span> <span class="sa">f</span><span class="s2">&quot;</span><span class="si">{</span><span class="n">uuid</span><span class="si">}</span><span class="s2">.parquet&quot;</span><span class="p">,</span> <span class="n">index</span><span class="o">=</span><span class="kc">False</span><span class="p">)</span>
215215
</span><span id="TimescaleDBDataAccess-62"><a href="#TimescaleDBDataAccess-62"><span class="linenos">62</span></a>
@@ -351,7 +351,7 @@ <h6 id="parameters">Parameters</h6>
351351
</span><span id="TimescaleDBDataAccess.fetch_data_as_parquet-56"><a href="#TimescaleDBDataAccess.fetch_data_as_parquet-56"><span class="linenos">56</span></a> <span class="k">for</span> <span class="n">_</span><span class="p">,</span> <span class="n">row</span> <span class="ow">in</span> <span class="n">chunk</span><span class="o">.</span><span class="n">iterrows</span><span class="p">():</span>
352352
</span><span id="TimescaleDBDataAccess.fetch_data_as_parquet-57"><a href="#TimescaleDBDataAccess.fetch_data_as_parquet-57"><span class="linenos">57</span></a> <span class="n">systime</span> <span class="o">=</span> <span class="n">row</span><span class="p">[</span><span class="s1">&#39;systime&#39;</span><span class="p">]</span>
353353
</span><span id="TimescaleDBDataAccess.fetch_data_as_parquet-58"><a href="#TimescaleDBDataAccess.fetch_data_as_parquet-58"><span class="linenos">58</span></a> <span class="n">timeslot_dir</span> <span class="o">=</span> <span class="n">Path</span><span class="p">(</span><span class="nb">str</span><span class="p">(</span><span class="n">systime</span><span class="o">.</span><span class="n">year</span><span class="p">),</span> <span class="nb">str</span><span class="p">(</span><span class="n">systime</span><span class="o">.</span><span class="n">month</span><span class="p">)</span><span class="o">.</span><span class="n">zfill</span><span class="p">(</span><span class="mi">2</span><span class="p">),</span> <span class="nb">str</span><span class="p">(</span><span class="n">systime</span><span class="o">.</span><span class="n">day</span><span class="p">)</span><span class="o">.</span><span class="n">zfill</span><span class="p">(</span><span class="mi">2</span><span class="p">),</span> <span class="nb">str</span><span class="p">(</span><span class="n">systime</span><span class="o">.</span><span class="n">hour</span><span class="p">)</span><span class="o">.</span><span class="n">zfill</span><span class="p">(</span><span class="mi">2</span><span class="p">))</span>
354-
</span><span id="TimescaleDBDataAccess.fetch_data_as_parquet-59"><a href="#TimescaleDBDataAccess.fetch_data_as_parquet-59"><span class="linenos">59</span></a> <span class="n">output_path</span> <span class="o">=</span> <span class="n">Path</span><span class="p">(</span><span class="n">output_dir</span><span class="p">,</span> <span class="sa">f</span><span class="s2">&quot;</span><span class="si">{</span><span class="n">uuid</span><span class="si">}</span><span class="s2">/</span><span class="si">{</span><span class="n">timeslot_dir</span><span class="si">}</span><span class="s2">&quot;</span><span class="p">)</span>
354+
</span><span id="TimescaleDBDataAccess.fetch_data_as_parquet-59"><a href="#TimescaleDBDataAccess.fetch_data_as_parquet-59"><span class="linenos">59</span></a> <span class="n">output_path</span> <span class="o">=</span> <span class="n">Path</span><span class="p">(</span><span class="n">output_dir</span><span class="p">,</span> <span class="n">timeslot_dir</span><span class="p">)</span>
355355
</span><span id="TimescaleDBDataAccess.fetch_data_as_parquet-60"><a href="#TimescaleDBDataAccess.fetch_data_as_parquet-60"><span class="linenos">60</span></a> <span class="n">output_path</span><span class="o">.</span><span class="n">mkdir</span><span class="p">(</span><span class="n">parents</span><span class="o">=</span><span class="kc">True</span><span class="p">,</span> <span class="n">exist_ok</span><span class="o">=</span><span class="kc">True</span><span class="p">)</span>
356356
</span><span id="TimescaleDBDataAccess.fetch_data_as_parquet-61"><a href="#TimescaleDBDataAccess.fetch_data_as_parquet-61"><span class="linenos">61</span></a> <span class="n">row</span><span class="o">.</span><span class="n">to_frame</span><span class="p">()</span><span class="o">.</span><span class="n">T</span><span class="o">.</span><span class="n">to_parquet</span><span class="p">(</span><span class="n">output_path</span> <span class="o">/</span> <span class="sa">f</span><span class="s2">&quot;</span><span class="si">{</span><span class="n">uuid</span><span class="si">}</span><span class="s2">.parquet&quot;</span><span class="p">,</span> <span class="n">index</span><span class="o">=</span><span class="kc">False</span><span class="p">)</span>
357357
</span></pre></div>

docs/timeseries_shaper/time_functions.html

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,7 @@
2424

2525
<h2>Submodules</h2>
2626
<ul>
27+
<li><a href="time_functions/timestamp_converter.html">timestamp_converter</a></li>
2728
<li><a href="time_functions/timezone_shift.html">timezone_shift</a></li>
2829
</ul>
2930

0 commit comments

Comments
 (0)