首页 > 解决方案 > Pandas Dataframe 转换为 DynamoDB 表

问题描述

我有一个以下格式的数据框。

在此处输入图像描述

我正在尝试将其移动到以下格式的 DynamoDB 表中。

设备ID 传感器类型 时间戳 最小最大平均

在下面的代码中苦苦挣扎..对此有任何帮助...

df = pd.DataFrame(col)
df['SensorValue'] = pd.to_numeric(df['SensorValue'], errors='coerce')
df['CurrentTime'] = pd.to_datetime(df['CurrentTime'])

minute = pd.Grouper(key='CurrentTime', freq='T')
df = df.groupby(['DeviceId','SensorDataType', minute]).SensorValue.agg(['min','max','mean'])


table1 = dynamodb.Table('bsm_data_table')
with table1.batch_writer() as batch:
    for index, row in df.iterrows():
        content = {
            'DeviceId', row['DeviceId'],
            'SensorDataType', row['SensorDataType'],
            'CurrentTime', row['CurrentTime'],
            'min', row['min'],
            'max',row['max'],
            'mean',row['mean']
        }
        batch.put_item(Item=content)

标签: amazon-dynamodbboto3

解决方案


推荐阅读