82 lines
1.7 KiB
Perl
82 lines
1.7 KiB
Perl
|
#!/usr/bin/perl
|
||
|
|
#
|
||
|
|
# DW::Task
|
||
|
|
#
|
||
|
|
# Base class for asynchronously executed tasks.
|
||
|
|
#
|
||
|
|
# Authors:
|
||
|
|
# Mark Smith <mark@dreamwidth.org>
|
||
|
|
#
|
||
|
|
# Copyright (c) 2019 by Dreamwidth Studios, LLC.
|
||
|
|
#
|
||
|
|
# This program is free software; you may redistribute it and/or modify it under
|
||
|
|
# the same terms as Perl itself. For a copy of the license, please reference
|
||
|
|
# 'perldoc perlartistic' or 'perldoc perlgpl'.
|
||
|
|
#
|
||
|
|
|
||
|
|
package DW::Task;
|
||
|
|
|
||
|
|
use strict;
|
||
|
|
use v5.10;
|
||
|
|
use Log::Log4perl;
|
||
|
|
my $log = Log::Log4perl->get_logger(__PACKAGE__);
|
||
|
|
|
||
|
|
use constant COMPLETED => 100;
|
||
|
|
use constant FAILED => 101;
|
||
|
|
|
||
|
|
sub new {
|
||
|
|
my ( $class, @args ) = @_;
|
||
|
|
|
||
|
|
my $self = { args => \@args };
|
||
|
|
return bless $self, $class;
|
||
|
|
}
|
||
|
|
|
||
|
|
sub args {
|
||
|
|
my $self = $_[0];
|
||
|
|
|
||
|
|
return $self->{args};
|
||
|
|
}
|
||
|
|
|
||
|
|
sub with_dedup {
|
||
|
|
my ( $self, %opts ) = @_;
|
||
|
|
$self->{uniqkey} = $opts{uniqkey};
|
||
|
|
$self->{dedup_ttl} = $opts{dedup_ttl};
|
||
|
|
return $self;
|
||
|
|
}
|
||
|
|
|
||
|
|
sub uniqkey {
|
||
|
|
return $_[0]->{uniqkey};
|
||
|
|
}
|
||
|
|
|
||
|
|
sub dedup_ttl {
|
||
|
|
return $_[0]->{dedup_ttl};
|
||
|
|
}
|
||
|
|
|
||
|
|
sub receive_count {
|
||
|
|
my ( $self, $val ) = @_;
|
||
|
|
$self->{_receive_count} = $val if defined $val;
|
||
|
|
return $self->{_receive_count} || 0;
|
||
|
|
}
|
||
|
|
|
||
|
|
sub queue_attributes {
|
||
|
|
my ( $self, %opts ) = @_;
|
||
|
|
|
||
|
|
my %attrs = (
|
||
|
|
DelaySeconds => 0,
|
||
|
|
MaximumMessageSize => 262_144,
|
||
|
|
MessageRetentionPeriod => 345_600,
|
||
|
|
ReceiveMessageWaitTimeSeconds => 10,
|
||
|
|
VisibilityTimeout => 300,
|
||
|
|
);
|
||
|
|
|
||
|
|
if ( $opts{dlq} ) {
|
||
|
|
my $arn =
|
||
|
|
sprintf( 'arn:aws:sqs:%s:%d:%s', $LJ::SQS{region}, $LJ::SQS{account}, $opts{dlq} );
|
||
|
|
$attrs{RedrivePolicy} = "{\"deadLetterTargetArn\":\"$arn\",\"maxReceiveCount\":3}";
|
||
|
|
}
|
||
|
|
|
||
|
|
return %attrs;
|
||
|
|
}
|
||
|
|
|
||
|
|
1;
|