计算 pandas 中每个日期员工的总工作时间

Par*_*dya 1 python pandas

我有这样的 pandas 数据框:

Employee_id  timestamp
   1        2017-06-21 04:47:45
   1        2017-06-21 04:48:45
   1        2017-06-21 04:49:45
Run Code Online (Sandbox Code Playgroud)

对于每位员工,如果他/她在办公室,我每 1 分钟就会收到 ping 信息。我有大约 2000 个员工的 ping,我需要如下输出:

Employee_id    date           Total_work_hour
     1      2018-06-21               8
     1      2018-06-22               7
     2      2018-06-21               6
     2      2018-06-22               8
Run Code Online (Sandbox Code Playgroud)

为全体 2000 名员工

jez*_*ael 5

使用groupbylambda 函数计算diff所有sum差异,然后将其转换为秒total_seconds并除以3600小时:

df1 = (df.groupby(['Employee_id', df['timestamp'].dt.date])['timestamp']
        .apply(lambda x: x.diff().sum())
        .dt.total_seconds()
        .div(3600)
        .reset_index(name='Total_work_hour'))
print (df1)
   Employee_id  timestamp  Total_work_hour
0            1 2017-06-21         0.033333
Run Code Online (Sandbox Code Playgroud)

但如果可能缺少一些连续分钟,可以使用自定义函数:

print (df)
   Employee_id           timestamp
0            1 2017-06-21 04:47:45
1            1 2017-06-21 04:48:45
2            1 2017-06-21 04:49:45
3            1 2017-06-21 04:55:45

def f(x):
    vals = x.diff()
    return vals.mask(vals > pd.Timedelta(60, unit='s')).sum()

df1 = (df.groupby(['Employee_id', df['timestamp'].dt.date])['timestamp']
        .apply(f)
        .dt.total_seconds()
        .div(3600)
        .reset_index(name='Total_work_hour')
        )
print (df1)
   Employee_id  timestamp  Total_work_hour
0            1 2017-06-21         0.033333
Run Code Online (Sandbox Code Playgroud)