weatherstation_data_populate.py 文件源码

def p_table (stations, datapoints): # Populate Table
    with db_r.Table('weatherstation_data').batch_writer() as batch:
        for station in trange(stations, desc='Stations'):
            for datapoint in trange(datapoints, desc='Datapoints'):
                item = item_gen(station)
                batch.put_item(Item=item)
#------------------------------------------------------------------------------