in bandit/src/query-lambda/dynamo.ts [28:62]
Item: buildDynamoRecord(rows, testName,channel, startTimestamp),
},
};
}
function buildDynamoRecord(
rows: VariantQueryRow[],
testName: string,
channel: string,
startTimestamp: string
): TestSample {
const variants = rows.map((row) => ({
variantName: row.variant_name,
annualisedValueInGBP: row.sum_av_gbp,
annualisedValueInGBPPerView: row.sum_av_gbp_per_view,
views: row.views,
}));
return {
testName: channel + "_" + testName,
variants,
timestamp: startTimestamp,
};
}
export function writeBatch(
batch: DocumentClient.WriteRequest[],
stage: string,
docClient: DocumentClient
): Promise<PromiseResult<DocumentClient.BatchWriteItemOutput, AWSError>> {
const table = `support-bandit-${stage.toUpperCase()}`;
return docClient
.batchWrite({
RequestItems: {