In [8]:
import xarray as xr
import numpy as np
import pandas as pd
%matplotlib inline
from matplotlib import pyplot as plt
from dask.diagnostics import ProgressBar
import seaborn as sns
from matplotlib.colors import LogNorm
We already downloaded a subsetted MODIS-Aqua chlorophyll-a dataset for the Arabian Sea.
We can read all the netcdf files into one xarray Dataset using the open_mfsdataset function. Note that this does not load the data into memory yet. That only happens when we try to access the values.
In [9]:
ds_8day = xr.open_mfdataset('./data_collector_modisa_chla9km/ModisA_Arabian_Sea_chlor_a_9km_*_8D.nc')
ds_daily = xr.open_mfdataset('./data_collector_modisa_chla9km/ModisA_Arabian_Sea_chlor_a_9km_*_D.nc')
both_datasets = [ds_8day, ds_daily]
How much data is contained here? Let's get the answer in MB.
In [10]:
print([(ds.nbytes / 1e6) for ds in both_datasets])
The 8-day dataset is ~534 MB while the daily dataset is 4.2 GB. These both easily fit in RAM. So let's load them all into memory
In [11]:
[ds.load() for ds in both_datasets]
Out[11]:
In [12]:
def fix_bad_data(ds):
# for some reason, the cloud / land mask is backwards on some data
# this is obvious because there are chlorophyl values less than zero
bad_data = ds.chlor_a.groupby('time').min() < 0
# loop through and fix
for n in np.nonzero(bad_data.values)[0]:
data = ds.chlor_a[n].values
ds.chlor_a.values[n] = np.ma.masked_less(data, 0).filled(np.nan)
In [13]:
[fix_bad_data(ds) for ds in both_datasets]
Out[13]:
In [14]:
ds_8day.chlor_a>0
Out[14]:
In [15]:
(ds_8day.chlor_a>0).sum(dim='time').plot()
Out[15]:
In [16]:
# find a mask for the land
ocean_mask = (ds_8day.chlor_a>0).sum(dim='time')>0
#ocean_mask = (ds_daily.chlor_a>0).sum(dim='time')>0
num_ocean_points = ocean_mask.sum().values # compute the total nonzeros regions(data point)
ocean_mask.plot()
plt.title('%g total ocean points' % num_ocean_points)
Out[16]:
In [17]:
#ds_8day
In [18]:
#ds_daily
In [19]:
plt.figure(figsize=(8,6))
ds_daily.chlor_a.sel(time='2002-11-18',method='nearest').plot(norm=LogNorm())
#ds_daily.chlor_a.sel(time=target_date, method='nearest').plot(norm=LogNorm())
Out[19]:
In [20]:
#list(ds_daily.groupby('time')) # take a look at what's inside
Now we count up the number of valid points in each snapshot and divide by the total number of ocean points.
In [21]:
'''
<xarray.Dataset>
Dimensions: (eightbitcolor: 256, lat: 144, lon: 276, rgb: 3, time: 4748)
'''
ds_daily.groupby('time').count() # information from original data
Out[21]:
In [22]:
ds_daily.chlor_a.groupby('time').count()/float(num_ocean_points)
Out[22]:
In [23]:
count_8day,count_daily = [ds.chlor_a.groupby('time').count()/float(num_ocean_points)
for ds in (ds_8day,ds_daily)]
In [24]:
#count_8day = ds_8day.chl_ocx.groupby('time').count()/float(num_ocean_points)
#coundt_daily = ds_daily.chl_ocx.groupby('time').count()/float(num_ocean_points)
#count_8day, coundt_daily = [ds.chl_ocx.groupby('time').count()/float(num_ocean_points)
# for ds in ds_8day, ds_daily] # not work in python 3
In [25]:
plt.figure(figsize=(12,4))
count_8day.plot(color='k')
count_daily.plot(color='r')
plt.legend(['8 day','daily'])
Out[25]:
In [26]:
count_8day_clim, coundt_daily_clim = [count.groupby('time.month').mean() # monthly data
for count in (count_8day, count_daily)]
In [27]:
# mean value of the monthly data on the count of nonzeros
plt.figure(figsize=(12,4))
count_8day_clim.plot(color='k')
coundt_daily_clim.plot(color='r')
plt.legend(['8 day', 'daily'])
Out[27]:
In [28]:
target_date = '2003-02-15'
plt.figure(figsize=(8,6))
ds_8day.chlor_a.sel(time=target_date, method='nearest').plot(norm=LogNorm())
Out[28]:
In [29]:
plt.figure(figsize=(8,6))
ds_daily.chlor_a.sel(time=target_date, method='nearest').plot(norm=LogNorm())
Out[29]:
In [30]:
ds_daily.chlor_a[0].sel_points(lon=[65, 70], lat=[16, 18], method='nearest') # the time is selected!
#ds_daily.chl_ocx[0].sel_points(time= times, lon=lons, lat=times, method='nearest')
Out[30]:
In [31]:
#ds_daily.chlor_a.sel_points?
In [32]:
ds_6day = ds_daily.resample('6D', dim='time')
ds_6day
Out[32]:
In [33]:
plt.figure(figsize=(8,6))
ds_6day.chlor_a.sel(time=target_date, method='nearest').plot(norm=LogNorm())
Out[33]:
In [34]:
# check the range for the longitude
print(ds_6day.lon.min(),'\n' ,ds_6day.lat.min())
In [35]:
# in the following we deal with the data from the gdp float
from buyodata import buoydata
import os
In [36]:
# a list of files
fnamesAll = ['./gdp_float/buoydata_1_5000.dat','./gdp_float/buoydata_5001_10000.dat','./gdp_float/buoydata_10001_15000.dat','./gdp_float/buoydata_15001_jun16.dat']
In [37]:
# read them and cancatenate them into one DataFrame
dfAll = pd.concat([buoydata.read_buoy_data(f) for f in fnamesAll]) # around 4~5 minutes
#mask = df.time>='2002-07-04' # we only have data after this data for chlor_a
dfvvAll = dfAll[dfAll.time>='2002-07-04']
sum(dfvvAll.time<'2002-07-04') # recheck whether the time is
Out[37]:
In [38]:
# process the data so that the longitude are all >0
print('before processing, the minimum longitude is%f4.3 and maximum is %f4.3' % (dfvvAll.lon.min(), dfvvAll.lon.max()))
mask = dfvvAll.lon<0
dfvvAll.lon[mask] = dfvvAll.loc[mask].lon + 360
print('after processing, the minimum longitude is %f4.3 and maximum is %f4.3' % (dfvvAll.lon.min(),dfvvAll.lon.max()) )
dfvvAll.describe()
Out[38]:
In [39]:
# Select only the arabian sea region
arabian_sea = (dfvvAll.lon > 45) & (dfvvAll.lon< 75) & (dfvvAll.lat> 5) & (dfvvAll.lat <28)
# arabian_sea = {'lon': slice(45,75), 'lat': slice(5,28)} # later use this longitude and latitude
floatsAll = dfvvAll.loc[arabian_sea] # directly use mask
print('dfvvAll.shape is %s, floatsAll.shape is %s' % (dfvvAll.shape, floatsAll.shape) )
In [40]:
# avoid run this line repeatedly
# visualize the float around global region
fig, ax = plt.subplots(figsize=(12,10))
dfvvAll.plot(kind='scatter', x='lon', y='lat', c='temp', cmap='RdBu_r', edgecolor='none', ax=ax)
# visualize the float around the arabian sea region
fig, ax = plt.subplots(figsize=(12,10))
floatsAll.plot(kind='scatter', x='lon', y='lat', c='temp', cmap='RdBu_r', edgecolor='none', ax=ax)
Out[40]:
In [41]:
# pands dataframe cannot do the resamplingn properly
# cause we are really indexing on ['time','id'], pandas.dataframe.resample cannot do this
# TypeError: Only valid with DatetimeIndex, TimedeltaIndex or PeriodIndex, but got an instance of 'MultiIndex'
print()
In [42]:
# dump the surface floater data from pandas.dataframe to xarray.dataset
floatsDSAll = xr.Dataset.from_dataframe(floatsAll.set_index(['time','id']) ) # set time & id as the index); use reset_index to revert this operation
floatsDSAll
Out[42]:
In [43]:
# resample on the xarray.dataset onto two-day frequency
floatsDSAll_6D =floatsDSAll.resample('6D', dim='time')
floatsDSAll_6D
Out[43]:
In [44]:
# transfer it back to pandas.dataframe for plotting
floatsDFAll_6D = floatsDSAll_6D.to_dataframe()
floatsDFAll_6D
floatsDFAll_6D = floatsDFAll_6D.reset_index()
floatsDFAll_6D
# visualize the subsamping of floats around arabian region
fig, ax = plt.subplots(figsize=(12,10))
floatsDFAll_6D.plot(kind='scatter', x='lon', y='lat', c='temp', cmap='RdBu_r', edgecolor='none', ax=ax)
Out[44]:
In [45]:
# get the value for the chllorophy for each data entry
floatsDFAll_6Dtimeorder = floatsDFAll_6D.sort_values(['time','id'],ascending=True)
floatsDFAll_6Dtimeorder # check whether it is time ordered!!
# should we drop nan to speed up??
Out[45]:
In [47]:
floatsDFAll_6Dtimeorder.lon.dropna().shape # the longitude data has lots of values (5013,)
Out[47]:
In [48]:
# a little test for the api in loops for the dataframe
# check df.itertuples? it is faster and preserves the data format
'''
chl_ocx=[]
for row in floats_timeorder.itertuples():
#print(row)
#print('row.time = %s, row.id=%d, row.lon=%4.3f, row.lat=%4.3f' % (row.time,row.id,row.lon,row.lat) )
tmp=ds_2day.chl_ocx.sel_points(time=[row.time],lon=[row.lon], lat=[row.lat], method='nearest') # interpolation
chl_ocx.append(tmp)
floats_timeorder['chl_ocx'] = pd.Series(chl_ocx, index=floats_timeorder.index)
chl_ocx[0].to_series
'''
Out[48]:
In [49]:
# this one line avoid the list above
# it took a really long time for 2D interpolation, it takes an hour
tmpAll = ds_6day.chlor_a.sel_points(time=list(floatsDFAll_6Dtimeorder.time),lon=list(floatsDFAll_6Dtimeorder.lon), lat=list(floatsDFAll_6Dtimeorder.lat), method='nearest')
print('the count of nan vaues in tmpAll is',tmpAll.to_series().isnull().sum())
In [50]:
#print(tmpAll.dropna().shape)
tmpAll.to_series().dropna().shape # (1920,) good values
Out[50]:
In [52]:
# tmp.to_series() to transfer it from xarray dataset to series
floatsDFAll_6Dtimeorder['chlor_a'] = pd.Series(np.array(tmpAll.to_series()), index=floatsDFAll_6Dtimeorder.index)
print("after editing the dataframe the nan values in 'chlor_a' is", floatsDFAll_6Dtimeorder.chlor_a.isnull().sum() ) # they should be the same values as above
# take a look at the data
floatsDFAll_6Dtimeorder
# visualize the float around the arabian sea region
fig, ax = plt.subplots(figsize=(12,10))
floatsDFAll_6Dtimeorder.plot(kind='scatter', x='lon', y='lat', c='chlor_a', cmap='RdBu_r', edgecolor='none', ax=ax)
def scale(x):
logged = np.log10(x)
return logged
#print(floatsAll_timeorder['chlor_a'].apply(scale))
floatsDFAll_6Dtimeorder['chlor_a_log10'] = floatsDFAll_6Dtimeorder['chlor_a'].apply(scale)
floatsDFAll_6Dtimeorder
#print("after the transformation the nan values in 'chlor_a_log10' is", floatsAll_timeorder.chlor_a_log10.isnull().sum() )
# visualize the float around the arabian sea region
fig, ax = plt.subplots(figsize=(12,10))
floatsDFAll_6Dtimeorder.plot(kind='scatter', x='lon', y='lat', c='chlor_a_log10', cmap='RdBu_r', edgecolor='none', ax=ax)
floatsDFAll_6Dtimeorder.chlor_a.dropna().shape # (1920,)
#floatsDFAll_6Dtimeorder.chlor_a_log10.dropna().shape # (1920,)
Out[52]:
In [53]:
# take the diff of the chlor_a, and this has to be done in xarray
# transfer the dataframe into xarry dataset again
# take the difference
floatsDFAll_6Dtimeorder
Out[53]:
In [54]:
# unstack() will provide a 2d dataframe
# reset_index() will reset all the index as columns
In [56]:
# prepare the data in dataset and about to take the diff
tmp = xr.Dataset.from_dataframe(floatsDFAll_6Dtimeorder.set_index(['time','id']) ) # set time & id as the index); use reset_index to revert this operation
# take the diff on the chlor_a
chlor_a_rate = tmp.diff(dim='time',n=1).chlor_a.to_series().reset_index()
# make the column to a proper name
chlor_a_rate.rename(columns={'chlor_a':'chl_rate'}, inplace='True')
chlor_a_rate
# merge the two dataframes {floatsDFAll_XDtimeorder; chlor_a_rate} into one dataframe based on the index {id, time} and use the left method
floatsDFAllRate_6Dtimeorder=pd.merge(floatsDFAll_6Dtimeorder,chlor_a_rate, on=['time','id'], how = 'left')
floatsDFAllRate_6Dtimeorder
# check
print('check the sum of the chlor_a before the merge', chlor_a_rate.chl_rate.sum())
print('check the sum of the chlor_a after the merge',floatsDFAllRate_6Dtimeorder.chl_rate.sum())
# visualize the chlorophyll rate, it is *better* to visualize at this scale
fig, ax = plt.subplots(figsize=(12,10))
floatsDFAllRate_6Dtimeorder.plot(kind='scatter', x='lon', y='lat', c='chl_rate', cmap='RdBu_r', vmin=-0.8, vmax=0.8, edgecolor='none', ax=ax)
# visualize the chlorophyll rate on the log scale
floatsDFAllRate_6Dtimeorder['chl_rate_log10'] = floatsDFAllRate_6Dtimeorder['chl_rate'].apply(scale)
floatsDFAllRate_6Dtimeorder
fig, ax = plt.subplots(figsize=(12,10))
floatsDFAllRate_6Dtimeorder.plot(kind='scatter', x='lon', y='lat', c='chl_rate_log10', cmap='RdBu_r', edgecolor='none', ax=ax)
#floatsDFAllRate_6Dtimeorder.chl_rate.dropna().shape # (1093,) data points
floatsDFAllRate_6Dtimeorder.chl_rate_log10.dropna().shape # (458,) data points..... notice, chl_rate can be negative, so do not take log10
Out[56]:
In [57]:
pd.to_datetime(floatsDFAllRate_6Dtimeorder.time)
type(pd.to_datetime(floatsDFAllRate_6Dtimeorder.time))
ts = pd.Series(0, index=pd.to_datetime(floatsDFAllRate_6Dtimeorder.time) ) # creat a target time series for masking purpose
# take the month out
month = ts.index.month
# month.shape # a check on the shape of the month.
selector = ((11==month) | (12==month) | (1==month) | (2==month) | (3==month) )
selector
print('shape of the selector', selector.shape)
print('all the data count in [11-01, 03-31] is', floatsDFAllRate_6Dtimeorder[selector].chl_rate.dropna().shape) # total (745,)
print('all the data count is', floatsDFAllRate_6Dtimeorder.chl_rate.dropna().shape ) # total (1093,)
In [58]:
# histogram for non standarized data
axfloat = floatsDFAllRate_6Dtimeorder[selector].chl_rate.dropna().hist(bins=100,range=[-0.3,0.3])
axfloat.set_title('6-Day chl_rate')
Out[58]:
In [59]:
# standarized series
ts = floatsDFAllRate_6Dtimeorder[selector].chl_rate.dropna()
ts_standardized = (ts - ts.mean())/ts.std()
axts = ts_standardized.hist(bins=100,range=[-0.3,0.3])
axts.set_title('6-Day standardized chl_rate')
Out[59]:
In [60]:
# all the data
fig, axes = plt.subplots(nrows=8, ncols=2, figsize=(12, 10))
fig.subplots_adjust(hspace=0.05, wspace=0.05)
for i, ax in zip(range(2002,2017), axes.flat) :
tmpyear = floatsDFAllRate_6Dtimeorder[ (floatsDFAllRate_6Dtimeorder.time > str(i)) & (floatsDFAllRate_6Dtimeorder.time < str(i+1)) ] # if year i
#fig, ax = plt.subplots(figsize=(12,10))
print(tmpyear.chl_rate.dropna().shape) # total is 1088
tmpyear.plot(kind='scatter', x='lon', y='lat', c='chl_rate', cmap='RdBu_r',vmin=-0.6, vmax=0.6, edgecolor='none', ax=ax)
ax.set_title('year %g' % i)
# remove the extra figure
ax = plt.subplot(8,2,16)
fig.delaxes(ax)
In [61]:
fig, axes = plt.subplots(nrows=7, ncols=2, figsize=(12, 10))
fig.subplots_adjust(hspace=0.05, wspace=0.05)
for i, ax in zip(range(2002,2016), axes.flat) :
tmpyear = floatsDFAllRate_6Dtimeorder[ (floatsDFAllRate_6Dtimeorder.time >= (str(i)+ '-11-01') ) & (floatsDFAllRate_6Dtimeorder.time <= (str(i+1)+'-03-31') ) ] # if year i
# select only particular month, Nov 1 to March 31
#fig, ax = plt.subplots(figsize=(12,10))
print(tmpyear.chl_rate.dropna().shape) # the total is 745
tmpyear.plot(kind='scatter', x='lon', y='lat', c='chl_rate', cmap='RdBu_r', vmin=-0.6, vmax=0.6, edgecolor='none', ax=ax)
ax.set_title('year %g' % i)
In [62]:
# let's output the data as a csv or hdf file to disk to save the experiment time
df_list = []
for i in range(2002,2017) :
tmpyear = floatsDFAllRate_6Dtimeorder[ (floatsDFAllRate_6Dtimeorder.time >= (str(i)+ '-11-01') ) & (floatsDFAllRate_6Dtimeorder.time <= (str(i+1)+'-03-31') ) ] # if year i
# select only particular month, Nov 1 to March 31
df_list.append(tmpyear)
df_tmp = pd.concat(df_list)
print('all the data count in [11-01, 03-31] is ', df_tmp.chl_rate.dropna().shape) # again, the total is (745,)
df_chl_out_6D_modisa = df_tmp[~df_tmp.chl_rate.isnull()] # only keep the non-nan values
#list(df_chl_out_XD.groupby(['id'])) # can see the continuity pattern of the Lagarangian difference for each float id
# output to a csv or hdf file
df_chl_out_6D_modisa.head()
Out[62]:
In [63]:
df_chl_out_6D_modisa.index.name = 'index' # make it specific for the index name
# CSV CSV CSV CSV with specfic index
df_chl_out_6D_modisa.to_csv('df_chl_out_6D_modisa.csv', sep=',', index_label = 'index')
# load CSV output
test = pd.read_csv('df_chl_out_6D_modisa.csv', index_col='index')
test.head()
Out[63]:
In [ ]: