@@ -25,18 +25,13 @@ def add_bulk_data_values(session, series, dvs_size):
25
25
df ['DateTimeUTC' ] = pd .to_datetime (df ['DateTimeUTC' ]).astype (datetime .datetime )
26
26
dvs = []
27
27
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 )
40
35
series .data_values = dvs
41
36
session .add_all (dvs )
42
37
session .commit ()
@@ -93,18 +88,14 @@ def add_series(session):
93
88
def add_data_values (session , series ):
94
89
dvs = []
95
90
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 )
108
99
109
100
series .data_values = dvs
110
101
session .add_all (dvs )
0 commit comments