6

我想构建一个扩展pandas.DataFrame——我们称之为它SPDF——它可以做的事情超出了简单的范围DataFrame：

import pandas as pd
import numpy as np


def to_spdf(func):
    """Transform generic output of `func` to SPDF.

    Returns
    -------
    wrapper : callable
    """
    def wrapper(*args, **kwargs):
        res = func(*args, **kwargs)
        return SPDF(res)

    return wrapper


class SPDF:
    """Special-purpose dataframe.

    Parameters
    ----------
    df : pandas.DataFrame

    """

    def __init__(self, df):
        self.df = df

    def __repr__(self):
        return repr(self.df)

    def __getattr__(self, item):
        res = getattr(self.df, item)

        if callable(res):
            res = to_spdf(res)

        return res


if __name__ == "__main__":

    # construct a generic SPDF
    df = pd.DataFrame(np.eye(4))
    an_spdf = SPDF(df)

    # call .diff() to obtain another SPDF
    print(an_spdf.diff())

现在，DataFrame那个返回 another的方法DataFrame，比如.diff()上面的 MWE，返回 me another SPDF，这很棒。但是，我还想欺骗链式方法，例如.resample('M').last()or最终.rolling(2).mean()生成一个SPDF。到目前为止我失败了，因为.rolling()等是 type callable，并且我的包装器to_spdf尝试SPDF从它们的输出构造一个而不“等待”.mean()或表达式的任何其他最后部分。任何想法如何解决这个问题？

谢谢。

4

2 回答 2

4

你应该正确地继承dataframe. 为了让copy-constructor方法起作用，pandas 描述了您必须设置_constructor属性（以及其他信息）。

您可以执行以下操作：

class SPDF(DataFrame):

    @property
    def _constructor(self):
        return SPDF

如果您需要在方法期间（例如）保留自定义attributes（不是functions-那些会在那里），那么您可以执行以下操作copy-constructordiff

class SPDF(DataFrame):
    _metadata = ['prop']
    prop = 1

    @property
    def _constructor(self):
        return SPDF

请注意，输出是所需的：

df = SPDF(np.eye(4))
print(type(df))
[<class '__main__.SPDF'>]
new = df.diff()
print(type(new))
[<class '__main__.SPDF'>]
于 2018-07-17T18:11:00.080 回答
0

如果您不想子类化DataFrame，您可以引入另一个类，例如PendingSPDF并用它包装非数据框对象：

import pandas as pd
import numpy as np


def to_spdf(func):
    """Transform generic output of `func` to SPDF.

    Returns
    -------
    wrapper : callable
    """
    def wrapper(*args, **kwargs):
        res = func(*args, **kwargs)
        if isinstance(res, pd.DataFrame):
            return SPDF(res)
        else:
            return PendingSPDF(res)

    return wrapper

class SPDF:
    """Special-purpose dataframe.

    Parameters
    ----------
    df : pandas.DataFrame

    """

    def __init__(self, df):
        self.df = df

    def __repr__(self):
        return repr(self.df)

    def __getattr__(self, item):
        res = getattr(self.df, item)

        if callable(res):
            res = to_spdf(res)

        return res

class PendingSPDF:
    def __init__(self, df):
        self.df = df

    def __getattr__(self, item):
        res = getattr(self.df, item)

        if callable(res):
            res = to_spdf(res)

        return res

if __name__ == "__main__":

    # construct a generic SPDF
    df = pd.DataFrame(np.eye(4))
    an_spdf = SPDF(df)

    # call .diff() to obtain another SPDF
    print(an_spdf.diff())
于 2018-07-20T19:09:28.433 回答