Skip to content
This repository was archived by the owner on Mar 27, 2023. It is now read-only.

Commit b418b5f

Browse files
committed
added basic celery worker
1 parent e6f56fe commit b418b5f

File tree

3 files changed

+48
-8
lines changed

3 files changed

+48
-8
lines changed

awscdk/awscdk/cdk_app_root.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,6 @@
55
from cert import SiteCertificate
66
from hosted_zone import HostedZone
77
from cloudfront import CloudFront
8-
from ecr import ElasticContainerRepo
98
from vpc import Vpc
109
from assets import Assets
1110
from rds import Rds
@@ -143,6 +142,7 @@ def __init__(
143142
self.backend.backend_task.task_role,
144143
self.backend_tasks.collectstatic_task.task_role,
145144
self.backend_tasks.create_superuser_task.task_role,
145+
self.celery_worker_service.celery_default_worker_task.task_role,
146146
]
147147

148148
for task_role in task_roles:

awscdk/awscdk/celery_workers.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,9 @@ def __init__(self, scope: core.Construct, id: str, **kwargs) -> None:
2020
self.celery_default_worker_task.add_container(
2121
"DefaultCeleryWorkerContaienr",
2222
image=scope.image,
23-
logging=ecs.LogDrivers.aws_logs(stream_prefix="Backend"),
23+
logging=ecs.LogDrivers.aws_logs(
24+
stream_prefix="CeleryDefaultWorker"
25+
),
2426
environment=scope.variables.regular_variables,
2527
secrets=scope.variables.secret_variables,
2628
command=[

awscdk/stack.yml

Lines changed: 44 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -283,8 +283,8 @@ Resources:
283283
Ref: VpcC3027511
284284
Metadata:
285285
aws:cdk:path: dev-mysite-com-stack/ApplicationLoadBalancer/ALB/SecurityGroup/Resource
286-
? ApplicationLoadBalancerALBSecurityGrouptodevmysitecomstackBackendBackendSecurityGroup987E976C8000947E9AB3
287-
: Type: AWS::EC2::SecurityGroupEgress
286+
ApplicationLoadBalancerALBSecurityGrouptodevmysitecomstackBackendBackendSecurityGroup987E976C8000947E9AB3:
287+
Type: AWS::EC2::SecurityGroupEgress
288288
Properties:
289289
GroupId:
290290
Fn::GetAtt:
@@ -959,8 +959,8 @@ Resources:
959959
- Ref: BackendBackendTaskExecutionRole3B22D4E5
960960
Metadata:
961961
aws:cdk:path: dev-mysite-com-stack/Backend/BackendTask/ExecutionRole/DefaultPolicy/Resource
962-
? BackendBackendSecurityGroupfromdevmysitecomstackApplicationLoadBalancerALBSecurityGroup41CD7D0380003CD57722
963-
: Type: AWS::EC2::SecurityGroupIngress
962+
BackendBackendSecurityGroupfromdevmysitecomstackApplicationLoadBalancerALBSecurityGroup41CD7D0380003CD57722:
963+
Type: AWS::EC2::SecurityGroupIngress
964964
Properties:
965965
IpProtocol: tcp
966966
Description: Load balancer to target
@@ -1027,6 +1027,43 @@ Resources:
10271027
Value: dev-mysite-com
10281028
Metadata:
10291029
aws:cdk:path: dev-mysite-com-stack/CeleryWorkerService/DefaultCeleryWorkerTask/TaskRole/Resource
1030+
CeleryWorkerServiceDefaultCeleryWorkerTaskTaskRoleDefaultPolicyBD07F2FF:
1031+
Type: AWS::IAM::Policy
1032+
Properties:
1033+
PolicyDocument:
1034+
Statement:
1035+
- Action:
1036+
- s3:GetObject*
1037+
- s3:GetBucket*
1038+
- s3:List*
1039+
- s3:DeleteObject*
1040+
- s3:PutObject*
1041+
- s3:Abort*
1042+
Effect: Allow
1043+
Resource:
1044+
- Fn::GetAtt:
1045+
- BackendAssetsAssetsBucket62473847
1046+
- Arn
1047+
- Fn::Join:
1048+
- ""
1049+
- - Fn::GetAtt:
1050+
- BackendAssetsAssetsBucket62473847
1051+
- Arn
1052+
- /*
1053+
- Action: secretsmanager:GetSecretValue
1054+
Effect: Allow
1055+
Resource:
1056+
Ref: VariablesDjangoSecretKeyE4FA41EE
1057+
- Action: secretsmanager:GetSecretValue
1058+
Effect: Allow
1059+
Resource:
1060+
Ref: RdsDBClusterDBSecret28397CCA
1061+
Version: "2012-10-17"
1062+
PolicyName: CeleryWorkerServiceDefaultCeleryWorkerTaskTaskRoleDefaultPolicyBD07F2FF
1063+
Roles:
1064+
- Ref: CeleryWorkerServiceDefaultCeleryWorkerTaskTaskRole6B1D91A7
1065+
Metadata:
1066+
aws:cdk:path: dev-mysite-com-stack/CeleryWorkerService/DefaultCeleryWorkerTask/TaskRole/DefaultPolicy/Resource
10301067
CeleryWorkerServiceDefaultCeleryWorkerTask14365B86:
10311068
Type: AWS::ECS::TaskDefinition
10321069
Properties:
@@ -1106,8 +1143,8 @@ Resources:
11061143
- Arn
11071144
Metadata:
11081145
aws:cdk:path: dev-mysite-com-stack/CeleryWorkerService/DefaultCeleryWorkerTask/Resource
1109-
? CeleryWorkerServiceDefaultCeleryWorkerTaskDefaultCeleryWorkerContaienrLogGroup31C824ED
1110-
: Type: AWS::Logs::LogGroup
1146+
CeleryWorkerServiceDefaultCeleryWorkerTaskDefaultCeleryWorkerContaienrLogGroup31C824ED:
1147+
Type: AWS::Logs::LogGroup
11111148
UpdateReplacePolicy: Retain
11121149
DeletionPolicy: Retain
11131150
Metadata:
@@ -1719,3 +1756,4 @@ Resources:
17191756
Type: AWS::CDK::Metadata
17201757
Properties:
17211758
Modules: aws-cdk=1.38.0,@aws-cdk/assets=1.38.0,@aws-cdk/aws-apigateway=1.38.0,@aws-cdk/aws-applicationautoscaling=1.38.0,@aws-cdk/aws-autoscaling=1.38.0,@aws-cdk/aws-autoscaling-common=1.38.0,@aws-cdk/aws-autoscaling-hooktargets=1.38.0,@aws-cdk/aws-batch=1.38.0,@aws-cdk/aws-certificatemanager=1.38.0,@aws-cdk/aws-cloudformation=1.38.0,@aws-cdk/aws-cloudfront=1.38.0,@aws-cdk/aws-cloudwatch=1.38.0,@aws-cdk/aws-codebuild=1.38.0,@aws-cdk/aws-codecommit=1.38.0,@aws-cdk/aws-codepipeline=1.38.0,@aws-cdk/aws-cognito=1.38.0,@aws-cdk/aws-ec2=1.38.0,@aws-cdk/aws-ecr=1.38.0,@aws-cdk/aws-ecr-assets=1.38.0,@aws-cdk/aws-ecs=1.38.0,@aws-cdk/aws-ecs-patterns=1.38.0,@aws-cdk/aws-elasticache=1.38.0,@aws-cdk/aws-elasticloadbalancing=1.38.0,@aws-cdk/aws-elasticloadbalancingv2=1.38.0,@aws-cdk/aws-events=1.38.0,@aws-cdk/aws-events-targets=1.38.0,@aws-cdk/aws-iam=1.38.0,@aws-cdk/aws-kms=1.38.0,@aws-cdk/aws-lambda=1.38.0,@aws-cdk/aws-logs=1.38.0,@aws-cdk/aws-rds=1.38.0,@aws-cdk/aws-route53=1.38.0,@aws-cdk/aws-route53-targets=1.38.0,@aws-cdk/aws-s3=1.38.0,@aws-cdk/aws-s3-assets=1.38.0,@aws-cdk/aws-s3-deployment=1.38.0,@aws-cdk/aws-sam=1.38.0,@aws-cdk/aws-secretsmanager=1.38.0,@aws-cdk/aws-servicediscovery=1.38.0,@aws-cdk/aws-sns=1.38.0,@aws-cdk/aws-sns-subscriptions=1.38.0,@aws-cdk/aws-sqs=1.38.0,@aws-cdk/aws-ssm=1.38.0,@aws-cdk/aws-stepfunctions=1.38.0,@aws-cdk/cloud-assembly-schema=1.38.0,@aws-cdk/core=1.38.0,@aws-cdk/custom-resources=1.38.0,@aws-cdk/cx-api=1.38.0,@aws-cdk/region-info=1.38.0,jsii-runtime=Python/3.6.8
1759+

0 commit comments

Comments
 (0)