add dt.epoch_* to series

py-polars/docs/source/reference/series.rst

@@ -205,6 +205,9 @@ The following methods are available under the `Series.dt` attribute.
     DateTimeNameSpace.mean
     DateTimeNameSpace.round
     DateTimeNameSpace.buckets
+    DateTimeNameSpace.epoch_days
+    DateTimeNameSpace.epoch_milliseconds
+    DateTimeNameSpace.epoch_seconds
 
 
 Strings

py-polars/polars/internals/series.py

@@ -3782,6 +3782,39 @@ def round(self, rule: str, n: int) -> Series:
         """
         return wrap_s(self._s.round_datetime(rule, n))
 
+    def epoch_days(self) -> Series:
+        """
+        Get the number of days since the unix EPOCH.
+        If the date is before the unix EPOCH, the number of days will be negative.
+
+        Returns
+        -------
+        Days as Int32
+        """
+        return wrap_s(self._s).cast(Date).cast(Int32)
+
+    def epoch_milliseconds(self) -> Series:
+        """
+        Get the number of milliseconds since the unix EPOCH
+        If the date is before the unix EPOCH, the number of milliseconds will be negative.
+
+        Returns
+        -------
+        Milliseconds as Int64
+        """
+        return self.timestamp()
+
+    def epoch_seconds(self) -> Series:
+        """
+        Get the number of seconds since the unix EPOCH
+        If the date is before the unix EPOCH, the number of seconds will be negative.
+
+        Returns
+        -------
+        Milliseconds as Int64
+        """
+        return wrap_s(self._s.dt_epoch_seconds())
+
 
 def _to_python_datetime(
     value: Union[int, float], dtype: Type[DataType]

py-polars/src/series.rs

@@ -1264,6 +1264,10 @@ impl PySeries {
             .into()),
         }
     }
+    pub fn dt_epoch_seconds(&self) -> PyResult<Self> {
+        let ms = self.series.timestamp().map_err(PyPolarsEr::from)?;
+        Ok((ms / 1000).into_series().into())
+    }
 
     pub fn peak_max(&self) -> Self {
         self.series.peak_max().into_series().into()