Hola,
Perdón, pero recién puedo ver la descripción del procesamiento que propones.
No me queda claro lo de "registros comprendidos entre comienzo y fin", pero en python el filtro por fecha se puede realizar simplemente comparando los strings de fecha. La etapa de mapeo continuaría con la extracción del campo relevante (la energía, o field2). Luego se puede utilizar la fecha (o la fecha-hora) como clave para el procesamiento y la reducción sería la suma que reportaría el consumo total por fecha (o fecha-hora, tal como se haya realizado el filtrado y la definición de la clave).
Si hay alguna complicación adicional que no entiendo por favor me la aclaras, para intentar ver una posible solución.
Saludos
SN