在GEE平台上分别利用Landsat和哨兵系列遥感影像对数据进行统一预处理预处理,然后提取水体面积结合DEM反演水位并构建反演模型来估算断面流量
这是之前尝试过的代码,但有部分出错且结果不对,需要更改帮助
用于Landsat8和9影像集的NDVI水体范围 提取
// ============================================================
// 1. 初始化检查
// ============================================================
if (typeof roi === 'undefined' || typeof dam === 'undefined') {
print('🛑 【严重错误】: 请先在地图上画 roi 和 dam!');
print('👉 1. 画一个多边形包住整个水库,重命名为 roi');
print('👉 2. 画一个多边形在大坝深水区,重命名为 dam');
} else {
Map.centerObject(roi, 11);
Map.setOptions("TERRAIN");
}
// ============================================================
// 2. 参数设置
// ============================================================
// Landsat 数据较少,建议时间范围长一点
var START_DATE = '2006-01-01';
var END_DATE = '2020-12-27';
var MAX_CLOUD_COVER = 30; // 允许20%的云量
// ============================================================
// 3. 核心函数:去云与水体提取
// ============================================================
// Landsat 去云函数 (使用 QA_PIXEL 波段)
function maskLsr(image) {
var qa = image.select('QA_PIXEL');
// 位操作:云(Bit 3) 和 云影(Bit 4)
var mask = qa.bitwiseAnd(1 << 3).eq(0)
.and(qa.bitwiseAnd(1 << 4).eq(0));
return image.updateMask(mask)
.copyProperties(image, ["system:time_start"]);
}
// 核心水体提取函数 (NDWI)
// 文献中使用的是 NDWI = (Green - NIR) / (Green + NIR)
var waterfunction = function(image){
// Landsat 8: B3=Green, B5=NIR;Landsat5/7:B2=green,B4=nir
var ndwi = image.normalizedDifference(['B3', 'B5']).rename('NDWI');
// 阈值判断:NDWI > 0 判定为水
var water = ndwi.gt(0.0).rename('Water');
return image.addBands(water).addBands(ndwi);
};
// ============================================================
// 4. 数据加载与处理
// ============================================================
// 合并 Landsat 8 和 Landsat 9 数据集
var l5 = ee.ImageCollection('LANDSAT/LC05/C02/T1_TOA');
var l7 = ee.ImageCollection('LANDSAT/LC07/C02/T1_TOA');
var l8= ee.ImageCollection('LANDSAT/LC08/C02/T1_TOA');
var landsat = l8.merge(l7)merge(l5)
.filterBounds(roi)
.filterDate(START_DATE, END_DATE)
.filter(ee.Filter.lt('CLOUD_COVER', MAX_CLOUD_COVER))
.map(function(image){ return image.clip(roi); })
.map(maskLsr) // 1. 去云
.map(waterfunction) // 2. 算水体
.sort('system:time_start');
print('筛选到的 Landsat 影像数量:', landsat.size());
// ============================================================
// 5. 数据清洗 (去除小斑块 & 错误高程)
// ============================================================
var Water_Clean = function(img) {
var water = img.select('Water');
// 使用 SRTM 高程
var alos = ee.Image("USGS/SRTMGL1_003").clip(roi).rename('Elevation');
// 逻辑:去除小于500像素的小碎块
var minSize = 500;
var count = water.connectedPixelCount(minSize);
// 逻辑:去除高程异常区 (三峡水库水面通常 < 175m)
// 原始代码是 alos.gt(640),这里改为 175
var filtered = water.where(count.lt(minSize).and(alos.gt(175)), 0);
return img.addBands(filtered.rename('Water_Clean'), null, true);
};
landsat = landsat.map(Water_Clean);
// ============================================================
// 6. 面积与水位计算
// ============================================================
var Water_Calc = function(img) {
var water = img.select('Water_Clean'); // 用清洗后的水体
var alos = ee.Image("USGS/SRTMGL1_003").clip(roi).rename('Elevation');
// 1. 计算面积 (km2)
var area = water.multiply(ee.Image.pixelArea()).divide(1e6)
.reduceRegion({
reducer: ee.Reducer.sum(),
geometry: roi,
scale: 30,
bestEffort: true,
maxPixels: 1e13
}).get('Water_Clean');
// 2. 计算水位 (m)
// 只在 dam 区域计算水面最大高程
var alos_masked = alos.updateMask(water);
var max_elev = alos_masked.reduceRegion({
reducer: ee.Reducer.max(),
geometry: dam,
scale: 30,
bestEffort: true,
maxPixels: 1e13
}).get('Elevation');
// 防止无效值报错
var water_level = ee.Algorithms.If(max_elev, max_elev, 0);
// 3. 计算水深 (三峡库底约 90m)
var water_depth = ee.Number(water_level).subtract(90);
return ee.Feature(null, {
'system:time_start': img.get('system:time_start'),
'date': img.date().format('YYYY-MM-dd'),
'area_km2': area,
'water_level_m': water_level,
'water_depth_m': water_depth
});
};
var resultTable = landsat.map(Water_Calc);
// ============================================================
// 7. 结果展示
// ============================================================
// 绘制图表
var chart = ui.Chart.feature.byFeature(resultTable, 'system:time_start', 'area_km2')
.setOptions({
title: '三峡水库水体面积 (Landsat 578)',
hAxis: {title: '日期'},
vAxis: {title: '面积 (km²)'},
lineWidth: 2,
pointSize: 4,
color: 'green' // 换个颜色区分一下
});
print(chart);
// 交互点击功能
var label = ui.Label('点击图表查看 Landsat 影像');
Map.add(label);
chart.onClick(function(xValue, yValue, seriesName) {
if (!xValue) return;
var equalDate = ee.Filter.equals('system:time_start', xValue);
var image = ee.Image(landsat.filter(equalDate).first());
// 真彩色显示 (B4, B3, B2)
var visParams = {bands: ['B4', 'B3', 'B2'], min: 0, max: 0.3};
var layer = ui.Map.Layer(image, visParams, 'Landsat 真彩色');
Map.layers().reset([layer]);
// 显示提取结果
var waterVis = {min: 0, max: 1, palette: ['transparent', 'blue']};
Map.addLayer(image.select('Water_Clean').selfMask(), waterVis, '提取水体');
print('已加载: ' + new Date(xValue).toLocaleDateString());
});
// ============================================================
// 8. 导出数据 (后台运行)
// ============================================================
// 推荐使用这个下载数据
Export.table.toDrive({
collection: resultTable,
description: 'Miyun_Water_Data_2016_2025_Landsat8/9',
fileFormat: 'CSV',
selectors: ['date', 'area_km2', 'water_level_m', 'water_depth_m']
});
用于Sentinel1 SAR otsu自动阈值处理
// ============================================================
// 1. 核心工具函数:Otsu 自动阈值算法
// ============================================================
function otsu(histogram) {
var counts = ee.Array(ee.Dictionary(histogram).get('histogram'));
var means = ee.Array(ee.Dictionary(histogram).get('bucketMeans'));
var size = means.length().get([0]);
var total = counts.reduce(ee.Reducer.sum(), [0]).get([0]);
var sum = means.multiply(counts).reduce(ee.Reducer.sum(), [0]).get([0]);
var mean = sum.divide(total);
var indices = ee.List.sequence(1, size);
var bss = indices.map(function(i) {
var aCounts = counts.slice(0, 0, i);
var aCount = aCounts.reduce(ee.Reducer.sum(), [0]).get([0]);
var aMeans = means.slice(0, 0, i);
var aMean = aMeans.multiply(aCounts)
.reduce(ee.Reducer.sum(), [0]).get([0])
.divide(aCount);
var bCount = total.subtract(aCount);
var bMean = sum.subtract(aCount.multiply(aMean)).divide(bCount);
return aCount.multiply(aMean.subtract(mean).pow(2))
.add(bCount.multiply(bMean.subtract(mean).pow(2)));
});
return means.sort(bss).get([-1]);
}
// ============================================================
// 2. 初始化检查
// ============================================================
if (typeof roi === 'undefined' || typeof dam === 'undefined') {
print('🛑 【严重错误】: 请先在地图上画 roi 和 dam!');
} else {
Map.centerObject(roi, 11);
Map.addLayer(ee.Image().byte().paint(roi, 1, 2), {palette: 'red'}, 'ROI');
}
// ============================================================
// 3. 数据处理 (2016-2025)
// ============================================================
var filterSpeckles = function(img) {
var vv = img.select('VV');
var vv_smoothed = vv.focal_median(100, 'circle', 'meters').rename('VV_Filtered');
return img.addBands(vv_smoothed);
};
var S1 = ee.ImageCollection('COPERNICUS/S1_GRD')
.filterBounds(roi)
.filterDate('2016-01-01', '2025-12-28')
.filter(ee.Filter.listContains('transmitterReceiverPolarisation', 'VV'))
.filter(ee.Filter.eq('instrumentMode', 'IW'))
.filter(ee.Filter.contains('.geo', roi))
.map(filterSpeckles);
print('正在后台准备处理影像数:', S1.size());
// ============================================================
// 4. 水体提取与计算 (强化日期处理)
// ============================================================
var Water_Calc = function(img) {
var alos = ee.Image("USGS/SRTMGL1_003").clip(roi).rename('Elevation');
var vv = img.select('VV_Filtered');
// Otsu 阈值计算
var histogramResult = vv.reduceRegion({
reducer: ee.Reducer.histogram(255, 2),
geometry: roi,
scale: 30,
bestEffort: true
});
var localHisto = histogramResult.get('VV_Filtered');
var thresholdNum = ee.Algorithms.If(localHisto, otsu(localHisto), -16);
var thresholdImg = ee.Image.constant(ee.Number(thresholdNum));
// 水体提取
var water = vv.lt(thresholdImg).rename('Water');
// 去噪
var minSize = 500;
var count = water.connectedPixelCount(minSize);
var filtered1 = water.where(count.lt(minSize).and(alos.gt(160)), water.not());
var water_final = water.updateMask(filtered1).rename('Water');
// 计算面积 (km2)
var area = water_final.multiply(ee.Image.pixelArea()).divide(1e6)
.reduceRegion({
reducer: ee.Reducer.sum(),
geometry: roi,
scale: 30,
bestEffort: true
}).get('Water');
// 计算水位 (m)
var alos_masked = alos.updateMask(water_final);
var max_elev = alos_masked.reduceRegion({
reducer: ee.Reducer.max(),
geometry: dam,
scale: 30,
bestEffort: true
}).get('Elevation');
// 【核心修改】:强制格式化日期字符串,确保导出时不丢失
var dateStr = ee.Date(img.get('system:time_start')).format('YYYY-MM-dd');
return ee.Feature(null, {
'system:time_start': img.get('system:time_start'), // 备份:原始时间戳
'date_str': dateStr, // 核心:强制字符串格式的日期
'area_km2': area,
'water_level_m': max_elev,
'threshold': thresholdNum
});
};
// 把影像集合转换成数据表
var resultTable = S1.map(Water_Calc);
// ============================================================
// 5. 导出任务 (V2 版本)
// ============================================================
// 1. 验证一下
var check = resultTable.first();
print('数据列检查 (应包含 date_str):', check);
// 2. 导出 Excel (CSV)
Export.table.toDrive({
collection: resultTable,
description: 'Miyun_Water_Data_Full_2016_2025_v2', // 改了文件名,防止搞混
fileFormat: 'CSV',
// 这里的 selectors 必须和上面 Feature 里的 key 一一对应
selectors: ['date_str', 'area_km2', 'water_level_m', 'threshold', 'system:time_start']
})用于Sentinel2组合NDVI和NDWI水体范围提取
// ============================================================
// 1. 初始化检查
// ============================================================
if (typeof roi === 'undefined' || typeof dam === 'undefined') {
print('🛑 【严重错误】: 请先在地图上画 roi 和 dam!');
} else {
Map.centerObject(roi, 11);
Map.setOptions("TERRAIN");
}
// ============================================================
// 2. 参数设置 (2016 - 至今)
// ============================================================
var START_DATE = '2016-01-01';
var END_DATE = '2025-12-29';
var MIN_CLOUD_PERCENT = 20;
// ============================================================
// 3. 核心函数:去云与指数计算
// ============================================================
// Sentinel-2 去云函数
function maskS2clouds(image) {
var qa = image.select('QA60');
var cloudBitMask = 1 << 10;
var cirrusBitMask = 1 << 11;
var mask = qa.bitwiseAnd(cloudBitMask).eq(0).and(
qa.bitwiseAnd(cirrusBitMask).eq(0));
// 【核心修复点】:这里我把 .copyProperties 改了
// 以前漏了 "date_str",现在加上了,数据就不会丢了
return image.updateMask(mask).divide(1e4)
.select("B.*")
.copyProperties(image, ["system:time_start", "date_str"]);
}
// 添加 NDWI (水体指数)
var addNDWI = function(image) {
return image.addBands(image.normalizedDifference(['B3', 'B8']).rename('NDWI'));
};
// 添加 NDVI (植被指数)
var addNDVI = function(image) {
return image.addBands(image.normalizedDifference(['B8', 'B4']).rename('NDVI'));
};
// 双重掩膜提取水体
var CombinedMask = function(image) {
var ndwi = image.select('NDWI');
var ndvi = image.select('NDVI');
var waterMask = ndwi.gte(0.1).and(ndvi.lte(0)).rename('Water');
return image.addBands(waterMask);
};
// ============================================================
// 4. 数据加载与按日合成
// ============================================================
var s2 = ee.ImageCollection('COPERNICUS/S2_HARMONIZED')
.filterBounds(roi)
.filter(ee.Filter.lte('CLOUDY_PIXEL_PERCENTAGE', MIN_CLOUD_PERCENT))
.filterDate(START_DATE, END_DATE)
.map(function(image) { return image.clip(roi); });
// 按日合成函数
function mosaicBy(imcol){
var imlist = imcol.toList(imcol.size());
var all_dates = imlist.map(function(im){ return ee.Image(im).date().format("YYYY-MM-dd"); });
var unique_dates = all_dates.distinct();
var mosaic_imlist = unique_dates.map(function(d){
var date1 = ee.Date(d);
var im = imcol
.filterDate(date1, date1.advance(1, "day"))
.mosaic();
// 这里生成了日期标签
return im.set(
"system:time_start", date1.millis(),
"date_str", d
);
});
return ee.ImageCollection(mosaic_imlist);
}
var s2day = mosaicBy(s2);
// 处理数据链
var S2_Processed = s2day
.map(maskS2clouds) // 现在这一步会保留日期了
.map(addNDWI)
.map(addNDVI)
.map(CombinedMask)
// 过滤无效影像
.map(function(img) {
var count = img.select('Water').reduceRegion({
reducer: ee.Reducer.count(),
geometry: roi,
scale: 200,
maxPixels: 1e13
}).get('Water');
return img.set('valid_pixels', count);
})
.filter(ee.Filter.gt('valid_pixels', 100));
print('2016至今有效影像数量:', S2_Processed.size());
// ============================================================
// 5. 面积计算
// ============================================================
var Water_Calc = function(img) {
var water = img.select('Water');
var alos = ee.Image("USGS/SRTMGL1_003").clip(roi).rename('Elevation');
// 1. 算面积
var area = water.multiply(ee.Image.pixelArea()).divide(1e6)
.reduceRegion({
reducer: ee.Reducer.sum(),
geometry: roi,
scale: 30,
bestEffort: true,
maxPixels: 1e13
}).get('Water');
// 2. 算水位
var alos_masked = alos.updateMask(water);
var max_elev = alos_masked.reduceRegion({
reducer: ee.Reducer.max(),
geometry: dam,
scale: 30,
bestEffort: true,
maxPixels: 1e13
}).get('Elevation');
var water_level = ee.Algorithms.If(max_elev, max_elev, 0);
// 获取日期
var dateStr = img.get('date_str');
return ee.Feature(null, {
'date': dateStr, // 这次肯定有值了!
'area_km2': area,
'water_level_m': water_level
});
};
var resultTable = S2_Processed.map(Water_Calc);
// ============================================================
// 6. 导出任务
// ============================================================
// 先在右边打印一下,确认日期是否存在
print('第一行数据检查 (date字段应为日期):', resultTable.first());
Export.table.toDrive({;