@@ -25,18 +25,13 @@ def add_bulk_data_values(session, series, dvs_size):
2525 df ['DateTimeUTC' ] = pd .to_datetime (df ['DateTimeUTC' ]).astype (datetime .datetime )
2626 dvs = []
2727 for record in df .to_dict ('records' )[:dvs_size ]:
28- dv = DataValue ()
29- dv .data_value = record ['DataValue' ]
30- dv .local_date_time = record ['LocalDateTime' ]
31- dv .utc_offset = record ['UTCOffset' ]
32- dv .date_time_utc = record ['DateTimeUTC' ]
33- dv .site_id = series .site_id
34- dv .variable_id = series .variable_id
35- dv .censor_code = record ['CensorCode' ]
36- dv .method_id = series .method_id
37- dv .source_id = series .source_id
38- dv .quality_control_level_id = series .quality_control_level_id
39- dvs .append (dv )
28+ timeseries_result_value = TimeSeriesResultValues ()
29+ timeseries_result_value .DataValue = record ["DataValue" ]
30+ timeseries_result_value .ValueDateTimeUTCOffset = record ["UTCOffset" ]
31+ timeseries_result_value .ValueDateTime = record ["DateTimeUTC" ]
32+ timeseries_result_value .CensorCodeCV = record ["CensorCode" ]
33+ timeseries_result_value .QualityCodeCV = series .quality_control_level_code
34+ dvs .append (timeseries_result_value )
4035 series .data_values = dvs
4136 session .add_all (dvs )
4237 session .commit ()
@@ -93,18 +88,14 @@ def add_series(session):
9388def add_data_values (session , series ):
9489 dvs = []
9590 for i in range (10 ):
96- dv = DataValue ()
97- dv .data_value = i
98- dv .local_date_time = datetime .datetime .now () - datetime .timedelta (days = i )
99- dv .utc_offset = 0
100- dv .date_time_utc = dv .local_date_time
101- dv .site_id = series .site_id
102- dv .variable_id = series .variable_id
103- dv .censor_code = "NC"
104- dv .method_id = series .method_id
105- dv .source_id = series .source_id
106- dv .quality_control_level_id = series .quality_control_level_id
107- dvs .append (dv )
91+ timeseries = TimeSeriesResultValues ()
92+ timeseries .DataValue = i
93+ timeseries .TimeAggregationInterval = datetime .datetime .now () - datetime .timedelta (days = i )
94+ timeseries .ValueDateTimeUTCOffset = 0
95+ timeseries .ValueDateTime = timeseries .TimeAggregationInterval
96+ timeseries .CensorCodeCV = "NC"
97+ timeseries .QualityCodeCV = series .quality_control_level
98+ dvs .append (timeseries )
10899
109100 series .data_values = dvs
110101 session .add_all (dvs )
0 commit comments