Transform jst into ZonedDateTimes
This commit is contained in:
parent
4fb138e52b
commit
41f8cfd0ae
23
src/db.jl
23
src/db.jl
|
@ -1,6 +1,8 @@
|
|||
using SQLite
|
||||
using DataFrames
|
||||
using Dates
|
||||
using TimeZones
|
||||
using WeatherNews.Helpers
|
||||
|
||||
"""
|
||||
sql_fn(db)
|
||||
|
@ -143,9 +145,11 @@ function load_schedule_joined(db)
|
|||
JOIN segment seg ON seg.id = s.segment_id
|
||||
LEFT JOIN caster c ON c.id = s.caster_id
|
||||
LEFT JOIN mscale m ON m.jst = s.jst
|
||||
ORDER BY jst DESC
|
||||
ORDER BY jst
|
||||
"""
|
||||
return DBInterface.execute(db, sql_select) |> DataFrame
|
||||
s = DBInterface.execute(db, sql_select) |> DataFrame
|
||||
s.jst = jst2zdt.(s.jst)
|
||||
return s
|
||||
end
|
||||
|
||||
#=
|
||||
|
@ -175,4 +179,19 @@ rs = @chain s begin
|
|||
sort(:median_views, rev=true)
|
||||
end
|
||||
|
||||
# Summarize views by day
|
||||
tf = Day(1)
|
||||
rs = @chain s begin
|
||||
dropmissing(:view_count)
|
||||
@subset(:view_count .!= 0)
|
||||
@subset(hour.(:jst) .!= 23)
|
||||
@transform(:jst2 = floor.(:jst, tf))
|
||||
@groupby(:jst2)
|
||||
@combine begin
|
||||
:views = sum(:view_count)
|
||||
end
|
||||
@subset(:views .> 100000)
|
||||
@select(:jst = :jst2, :views)
|
||||
end
|
||||
|
||||
=#
|
||||
|
|
Loading…
Reference in New Issue