Consume kinesis logs while task is RUNNING status
parent
aca1ff1974
commit
6aec635bd4
File diff suppressed because one or more lines are too long
|
|
@ -106,6 +106,16 @@ class AWS {
|
||||||
// watching logs
|
// watching logs
|
||||||
const kinesis = new SDK.Kinesis();
|
const kinesis = new SDK.Kinesis();
|
||||||
|
|
||||||
|
const getTaskStatus = async () => {
|
||||||
|
const tasks = await ECS.describeTasks({
|
||||||
|
cluster: clusterName,
|
||||||
|
tasks: [task.tasks[0].taskArn],
|
||||||
|
}).promise();
|
||||||
|
core.info(`Task status is ${tasks.tasks[0].lastStatus}`);
|
||||||
|
return tasks.tasks[0].lastStatus;
|
||||||
|
};
|
||||||
|
|
||||||
|
while ((await getTaskStatus()) === 'RUNNING') {
|
||||||
const iterator = await kinesis
|
const iterator = await kinesis
|
||||||
.getShardIterator({
|
.getShardIterator({
|
||||||
ShardIteratorType: 'TRIM_HORIZON',
|
ShardIteratorType: 'TRIM_HORIZON',
|
||||||
|
|
@ -121,6 +131,7 @@ class AWS {
|
||||||
})
|
})
|
||||||
.promise();
|
.promise();
|
||||||
core.info(records.Records[0].Data);
|
core.info(records.Records[0].Data);
|
||||||
|
}
|
||||||
|
|
||||||
await ECS.waitFor('tasksStopped', {
|
await ECS.waitFor('tasksStopped', {
|
||||||
cluster: clusterName,
|
cluster: clusterName,
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue