Forecasting of forest drought impacts in Switzerland from satellite imagery, weather reanalysis and remote sensing data. Pixel-wise forecasts with feature engineering to provide model explainability.
Proposed workflow to collect data, process it and use it for drought impact forecasting.
├── README.md > This file contains a description of what is the repository used for and how to use it.
├── environment.yaml > Packages and requirements
├── earthnet-minicuber > Package for downloading datacubes. https://github.com/geco-bern/earthnet-minicuber
├── sampling > Forlder for scripts concerning scene sampling in Switzerland.
├── rasterise.py > Rasterise, upsample and normalise shapefiles to use as masks in sampling.
├── sample.py > Sampling algorithms.
├── sampling.ipynb > Example notebook.
├── sampled_coordinates > Folder containing text files of the sampled coordinates.
├── generated_cubes > Folder containing text files of the downloaded cubes.
├── data_downloading > Folder for scripts concering downloading of data.
├── swiss_dem_download.py > Download DEM tiles from swisstopo
├── reproject_dem.py > Reproject the DEM tiles to CRS EPSG:4326
├── mosaic_dem.py > Mosaic the tiles together into one single raster file.
├── mosaic_dem_recursive.py > Mosaic the tiles together into one single raster file ina recursive manner (by subgroup, then merging those)
├── swiss_dem_urls > Folder containing download URLs by canton.
├── *.txt > URLs for a given canton.
├── create_dataset.py > Generate a dataset of minicubes.
├── cloud_cleaning.py > Remove and replace cloud coevred values in Sentinel-2 data.
├── config.py > Configuration file for dataset creation.
├── delete_cubes_samples.py > Delete cubes and its samples from a list of coordinates.
├── delete_samples_bycoords.py > Delete cubes and its samples from a lat/lon bouds.
├── split_train_test.py > Organise generated samples into train/test sets.
├── feature_engineering > Folder containing scripts for the creation of topographic features from DEM(s).
├── create_dem_feat.py > Functions to create multiple features from DEM(s) and adjust generated raster files.
├── feature_engineer.py > Functions to extract individual properties from DEM (based on WhiteboxTools package).
├── geospatial_data_utils.py > Helper functions for manipulation raster data in python.
├── run_topo_feaets.py > Final script for topo feature engineering.
├── topo_features.ipynb > Example notebook.
├── create_forest_mask.py > Generate binary forest mask from forest shapefile in Switzerland.
├── add_static_data.py > Add time-invariant layers to the data cubes.
├── add_bands.py > Add additional features to the data cube (either computed or using add_static_data.py)
├── bands_info.py > Contains paths and descriptions of local static data to add.
├── modelling > Folder for modelling forest drought impacts.
├── README.md > Contains instructions on how to launch model training and testing.
We recommend using Anaconda for managing dependencies of this library. The following bash commands create a suitable environment.
- In the root directory, run
conda env create -f environment.yamlto create the environment (named minicuber by default). - Run
conda activate minicuberto activate the environment.
The first step is to identify locations around Switzerland. In particular, we collect the center coordinates of scenes of 2.56km x 2.56 km that will then be called during Data Downloading. The approach here uses a shapefile of the forests in Switzerland, as well as some polygons that label droughts (obtained from Brun et al., 2020. https://doi.org/10.1111/gcb.15360). We want to ensure that we sample scenes containing drought events, as well as scenes across all the country.
Reminder: by sampling N scenes you will be sampling > N data samples. For each pixel, multiple timeseries can be generateed too.
How to sample coordinates
- Rasterise your shapefiles, reproject, and upsample to a 2.56km resolution where each pixel is a continuous value between 0-1 (e.g. proportion of forest contained in each pixel). Use
sampling/rasterise.pyand refer tosampling/sampling.ipynb. - Sample scenes with containing drought labels
from sampling.sample import *
forest_mask_256 = ... # Path to forest mask with 2.56km resolution (EPSG:4326)
drought_labels_256 = ... # Path to drought mask with 2.56km resolution (EPSG:4326)
thresh_drought = 0 # Sample scenes with > thresh_drought
thresh_forest = 0.4 # Sample scenes with > thresh_forest
output_file_path = 'coords_drought.txt' # Define the output text file path
N = 100 # Number of scenes to sample. Will randomly keep N scenes
sample_drought(forest_mask_256, drought_labels_256, thresh_drought, thresh_forest, output_file_path, N)
- Sample scenes that have NO positive drought labels. Split Switzerland in 6 subregions. For each subregion, get randomly N/6 scenes in each subregions.
from sampling.sample import *
forest_mask_256 = ... # Path to forest mask with 2.56km resolution (EPSG:4326)
drought_labels_256 = ... # Path to drought mask with 2.56km resolution (EPSG:4326)
thresh_forest = 0.4 # Sample scenes with > thresh_forest
output_file_path = 'coords_negative_drought.txt' # Define the output text file path
N = 100 # Number of scenes to sample
sample_negatives(forest_mask_256, drought_labels_256, thresh_forest, output_file, N)
Make sure that you have gone through step 2. Feature Engineering and that your local features are ready to be added to the dataset!
To create pixel timeseries from multiple data sources, we use the earthnet-minicuber package (https://github.com/geco-bern/earthnet-minicuber) to obtain spatio-temporal data (time-series of a scene for multiple bands). A minicube contains spatio-temporal data ready for machine learning applications. It usually contains satellite imagery and additional remote sensing data, all regridded to a common grid.
To this cube, custom/local data can be added. Cloud removal on Sentinel-2 data can be done and pixel timeseries are sampled from the scene using a forest mask.
Setup
The format of the data that will be downloaded and the samples that will be created are set up in the data_downloading/config.py. The parameters to modify are:
coord_list_paths: list of paths to text files from which to read coordinates (generated during sampling).specs: Specifications passed to earthnet-minicuber, defining region, time and bands of interest. For more details of the possible cube specifications, check theearthnet-minicubercode.specs_add_bands: Specifications for adding locally stored data (including forest mask). The data will be added in the same resolution, projection and within the same bounds as the existing data in the minicube. There are two types of features that can be added to the minicube.- temporal: bands computed using the raw data in the cube, among ['NDVI']
- static/local features: include topographic, vegetation and soil features. The possible features that can be added and their meaning are detailed in
feature_engineering/bands_info.py. Add paths and descriptions there.
bands_to_drop: list of bands to remove from final pixel timeseries.root_dir: Where generated data should be stored.split: train/validation/testcontext: Number of context framestarget: Number of target framesshift: Shift between Sentinel-2 and ERA5. ERA5 will be shifted n steps forward with respect to Sentinel-2, but the timestamps used for naming files are those of Sentinel-2.cloud_cleaning: maximum number of consecutive missing values (in NDVI timeseries) for which cloud cleaning will be performed. If > cloud_cleaning, the pixel will not be used as a data sample. If 0/None no cloud cleaning is done.normalisation: If True, compute min/max for each band in the training set.remove_pct: In cloud cleaning, remove lower x% of values per week of year (provide the percent as decimal between 0 and 1).loess_frac: Fraction of data to consider in timeseries when applying LOESS smoothing.target_in_summer: If True, data samples will be created only if the start date of the target (label) is contained in Jun. 1st- Sep. 1st. Relevant for val/test set.drought_labels: use a drought mask to sample pixelsforest_thresh: minimum fraction of pixel covered by forest for samplingdrought_thresh: minimum fraction of pixel covered by drought label for samplingpixs_per_scene: optional. Limit to number of pixels to be sampled in a scene to generate model samples.gen_samples: if True, will generate samples even if cube exists already (could overwrite existing samples).
Example of cloud cleaning performed for NDVI timeseries
How to create dataset
Downloaded cubes will be saved in config.root_dir/config.split/cubes/ as startyear_startmonth_startday_endyear_endmonth_endday_lon_lat_width_height.nc
Generated samples are saved in config.root_dir/config.split/ as startyear_startmonth_startday_endyear_endmonth_endday_lon_lat_width_height_shift.npz, where context and target data can be accessed with npz["context"] and npz["target"]. The start date and end date are those of the context tensor.
- Download the required code to generate minicubes: https://github.com/geco-bern/earthnet-minicuber. Ideally, place this repository as suggested in the Repository Structure.
- Also edit the dictionaries in
feature_engineering/add_bands.pyandfeature_engineering/add_static_data.pyto include all of you filenames and path to local features you may have. - Edit
data_downloading/config.py - Launch the dataset creation
python data_downloading/create_dataset.py --config_path /path/to/config/file/
The image below shows the center coordinates for the cubes that were downloaded and from which samples were generated in sampling/generated_cubes. In this case, 'drought' (samples generated from cubes containing drought labels) and 'negative' (samples generated from cubes NOT containing drought labels) datasets were created using two different configuration files.
Sampled cube coordinates, generating 180GB and 27GB of negative and drought samples respectively.
How to split data into train and test
You can reshuffle the data you created into new train and test folders. Running this script will change the folder structure, so be careful to have backups if needed!
Provide the paths to where your data samples are stored, and the bounding box (and/or time range) for the train set. Anything outside these bounds (and/or time range) will be usd for the test set. All cubes will be moved to train. Train and test will have same .npy normalisation stats, and any usused stats will be saved in train/cubes.
python data_downloading/split_train_test.py --data_paths path/to/dataset1 path/to/dataset2 --dir_path folder/to/store/new/splits --coord_range minX minY maxX maxY
Download the DEM from Swisstopo (at 0.5 or 2 m resolution). The DEM is split into tiles that need to be downloaded individually.
The scripts are found in data_downloading/.
Disclaimer: This will produce a high resolution DEM for the whole of Switzerland, ensure you have enough storage space (min 265GB for the 2 m resolution DEM). Furthermore, the data processing might require a lot of RAM. It is advised to only download and process the DEM for your region of interest.
How to use:
- Go to https://www.swisstopo.admin.ch/fr/geodata/height/alti3d.html and request the whole dataset of tiles. This will provide you with a list of URLs that you can call to download.
- Copy the URLs and save them to a
.txtfile. The URLs for the DEM at 2 m resolution (in 2022) is provided (urls_all.txt). The URLs have also been seperated by canton and are provided indata_downloading/swiss_dem/swiss_dem_urls/. - Using the
swiss_dem_download.pyscript, provide the path to this.txtfile and the path to where you want the DEM tiles to be downloaded. Run the script from terminal by calling
python data_downloading/swiss_dem_download.py --urls_path 'urls_all.txt' --downloads_path 'path/to/store/downloads/'
- The DEM tiles need to be reprojected to a global CRS (EPSG:4326) from local CRS (MN95 NF02). New rasters named
*_reprojected.tiffwill be created. The tiles are reprojected to a 20 m resolution by default, but could also be other if edited in the script.
python data_downloading/reproject_dem.py --folder_path 'path/to/dem/tiles/' --reproj_path 'path/to/store/reproj/tiles/' --res 20
- Create a single DEM raster by mosaicking the (reprojected) tiles together. Ensure that the paths are correct in the script.
python data_downloading/mosaic_dem.py --folder_path 'path/to/tiles/to/merge/' --output_path 'path/to/output/raster/'
If you are doing this for a large area (e.g. whole of Switzerland), you might not be able to load all DEM tiles into memory. In this case, mosaicking can be done recursively, by combining groups of files at the time. You can define the number of tiles to be grouped together in the n_sub variable:
python data_downloading/mosaic_dem_recursive.py --folder_path 'path/to/tiles/to/merge/' --n_sub 1000 --output_folder 'path/to/output/folder/'
Additional environmental data can be downloaded. Refer to https://github.com/geco-bern/data_management for data availability. These are time-invariant data and can be stored locally (~10GB). For ideal use, store all "static data" in a same folder. Relevant data includes [Name, (repository)]:
- Forest mask for Switzerland (forestmaskswiss_waser_2015)
- Vegetation height Switzerland (vegheight_ginzler_2015)
- Swiss forest composition (forestcompositionswiss_waser_2017)
- High-resolution soil maps for the Swiss forest (somach_baltensweiler_2021)
Features can be derived from a DEM. Multiple DEMs at different resolutions can be used, meaning that these features will be computed at different resolutions.
To obtain DEMs at different resolutions than the 20m one you can use the following code. First, any missing values will be filled in using the rasterio.fill algorithm (https://rasterio.readthedocs.io/en/latest/api/rasterio.fill.html). Then the DEM is resampled to the resolutions you input in meters. If you desire other resolutions, modify the start of the script to provide other options (you need to provide a conversion between meters and degrees in EPSG:4326).
python feature_engineering/dem_smooth_resample.py --dem_path /path/to/dem/ --smooth_dem_path /path/output/filled/dem --resolutions 100 500 --output_folder /path/store/resampled/dems/
Because the resolution of the other data in the minicube is likely higher than the downsampled DEMs, a resampling is done when combining these layers to the rest. We use nearest interpolation method to simply "split" are larger pixel into smaller ones, so that we can conserve the properties of the lower resolution DEMs (done automatically in dataset creation scripts). When generating other topographic features, this step is already included in the code.
How to generate topographic features
Supported features are slope, apsect (will automatically generate northing and easting), ruggedness index, curvature, terrain wetness index. These are computed using the WhiteboxTools package. Additional features can be computed by adding functions to the feauture_engineering/feature_engineer.py script. For more information on WhiteboxTools and its functions: https://www.whiteboxgeo.com/manual/wbt_book/preface.html.
To generate the feature, edit the following variables in feauture_engineering/run_topo_feats.py:
list_paths: list of DEM files from which features should be generatedtarget: all generated features will be matched (in final resolution and shape) to this DEM tiff (usually the original DEM)feat_list: list of feature to compute among ['slope', 'aspect', 'rugg', 'curv', 'twi']out_path: path to store resulting raster files. Ideally, store these in the same folder as the static features.list_suffix: optional. If using multiple DEMs, provide a list of suffixes to differentiate the features generated from various DEMs. This suffix will be added to features' files names (for example the resolution). The order of the suffixes should respect the order inlist_paths. Then run:
python feature_engineering/run_topo_feats.py
Forecast NDVI n steps ahead using the data generated in the previous steps.
A README.md is provided in this folder for more details on training and testing models.