| .. | |||||
| __pycache__ | |||||
| __init__.py | |||||
| codedeploy.py | |||||
| deregister.py | |||||
| install.py | |||||
| locationargs.py | |||||
| push.py | |||||
| register.py | |||||
| systems.py | |||||
| uninstall.py | |||||
| utils.py |
| Server IP : 104.21.46.92 / Your IP : 104.23.197.222 Web Server : Apache/2.4.51 (Unix) OpenSSL/1.1.1n System : Linux ip-172-26-8-243 4.19.0-27-cloud-amd64 #1 SMP Debian 4.19.316-1 (2024-06-25) x86_64 User : daemon ( 1) PHP Version : 7.4.24 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : ON | Pkexec : ON Directory : /usr/lib/python3/dist-packages/awscli/customizations/codedeploy/ |
Upload File : |
# Copyright 2015 Amazon.com, Inc. or its affiliates. All Rights Reserved.
#
# Licensed under the Apache License, Version 2.0 (the "License"). You
# may not use this file except in compliance with the License. A copy of
# the License is located at
#
# http://aws.amazon.com/apache2.0/
#
# or in the "license" file accompanying this file. This file is
# distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF
# ANY KIND, either express or implied. See the License for the specific
# language governing permissions and limitations under the License.
import os
import sys
import zipfile
import tempfile
import contextlib
from datetime import datetime
from botocore.exceptions import ClientError
from awscli.compat import six
from awscli.customizations.codedeploy.utils import validate_s3_location
from awscli.customizations.commands import BasicCommand
from awscli.compat import ZIP_COMPRESSION_MODE
ONE_MB = 1 << 20
MULTIPART_LIMIT = 6 * ONE_MB
class Push(BasicCommand):
NAME = 'push'
DESCRIPTION = (
'Bundles and uploads to Amazon Simple Storage Service (Amazon S3) an '
'application revision, which is a zip archive file that contains '
'deployable content and an accompanying Application Specification '
'file (AppSpec file). If the upload is successful, a message is '
'returned that describes how to call the create-deployment command to '
'deploy the application revision from Amazon S3 to target Amazon '
'Elastic Compute Cloud (Amazon EC2) instances.'
)
ARG_TABLE = [
{
'name': 'application-name',
'synopsis': '--application-name <app-name>',
'required': True,
'help_text': (
'Required. The name of the AWS CodeDeploy application to be '
'associated with the application revision.'
)
},
{
'name': 's3-location',
'synopsis': '--s3-location s3://<bucket>/<key>',
'required': True,
'help_text': (
'Required. Information about the location of the application '
'revision to be uploaded to Amazon S3. You must specify both '
'a bucket and a key that represent the Amazon S3 bucket name '
'and the object key name. Content will be zipped before '
'uploading. Use the format s3://\<bucket\>/\<key\>'
)
},
{
'name': 'ignore-hidden-files',
'action': 'store_true',
'default': False,
'group_name': 'ignore-hidden-files',
'help_text': (
'Optional. Set the --ignore-hidden-files flag to not bundle '
'and upload hidden files to Amazon S3; otherwise, set the '
'--no-ignore-hidden-files flag (the default) to bundle and '
'upload hidden files to Amazon S3.'
)
},
{
'name': 'no-ignore-hidden-files',
'action': 'store_true',
'default': False,
'group_name': 'ignore-hidden-files'
},
{
'name': 'source',
'synopsis': '--source <path>',
'default': '.',
'help_text': (
'Optional. The location of the deployable content and the '
'accompanying AppSpec file on the development machine to be '
'zipped and uploaded to Amazon S3. If not specified, the '
'current directory is used.'
)
},
{
'name': 'description',
'synopsis': '--description <description>',
'help_text': (
'Optional. A comment that summarizes the application '
'revision. If not specified, the default string "Uploaded by '
'AWS CLI \'time\' UTC" is used, where \'time\' is the current '
'system time in Coordinated Universal Time (UTC).'
)
}
]
def _run_main(self, parsed_args, parsed_globals):
self._validate_args(parsed_args)
self.codedeploy = self._session.create_client(
'codedeploy',
region_name=parsed_globals.region,
endpoint_url=parsed_globals.endpoint_url,
verify=parsed_globals.verify_ssl
)
self.s3 = self._session.create_client(
's3',
region_name=parsed_globals.region
)
self._push(parsed_args)
def _validate_args(self, parsed_args):
validate_s3_location(parsed_args, 's3_location')
if parsed_args.ignore_hidden_files \
and parsed_args.no_ignore_hidden_files:
raise RuntimeError(
'You cannot specify both --ignore-hidden-files and '
'--no-ignore-hidden-files.'
)
if not parsed_args.description:
parsed_args.description = (
'Uploaded by AWS CLI {0} UTC'.format(
datetime.utcnow().isoformat()
)
)
def _push(self, params):
with self._compress(
params.source,
params.ignore_hidden_files
) as bundle:
try:
upload_response = self._upload_to_s3(params, bundle)
params.eTag = upload_response['ETag'].replace('"', "")
if 'VersionId' in upload_response:
params.version = upload_response['VersionId']
except Exception as e:
raise RuntimeError(
'Failed to upload \'%s\' to \'%s\': %s' %
(params.source,
params.s3_location,
str(e))
)
self._register_revision(params)
if 'version' in params:
version_string = ',version={0}'.format(params.version)
else:
version_string = ''
s3location_string = (
'--s3-location bucket={0},key={1},'
'bundleType=zip,eTag={2}{3}'.format(
params.bucket,
params.key,
params.eTag,
version_string
)
)
sys.stdout.write(
'To deploy with this revision, run:\n'
'aws deploy create-deployment '
'--application-name {0} {1} '
'--deployment-group-name <deployment-group-name> '
'--deployment-config-name <deployment-config-name> '
'--description <description>\n'.format(
params.application_name,
s3location_string
)
)
@contextlib.contextmanager
def _compress(self, source, ignore_hidden_files=False):
source_path = os.path.abspath(source)
appspec_path = os.path.sep.join([source_path, 'appspec.yml'])
with tempfile.TemporaryFile('w+b') as tf:
zf = zipfile.ZipFile(tf, 'w', allowZip64=True)
# Using 'try'/'finally' instead of 'with' statement since ZipFile
# does not have support context manager in Python 2.6.
try:
contains_appspec = False
for root, dirs, files in os.walk(source, topdown=True):
if ignore_hidden_files:
files = [fn for fn in files if not fn.startswith('.')]
dirs[:] = [dn for dn in dirs if not dn.startswith('.')]
for fn in files:
filename = os.path.join(root, fn)
filename = os.path.abspath(filename)
arcname = filename[len(source_path) + 1:]
if filename == appspec_path:
contains_appspec = True
zf.write(filename, arcname, ZIP_COMPRESSION_MODE)
if not contains_appspec:
raise RuntimeError(
'{0} was not found'.format(appspec_path)
)
finally:
zf.close()
yield tf
def _upload_to_s3(self, params, bundle):
size_remaining = self._bundle_size(bundle)
if size_remaining < MULTIPART_LIMIT:
return self.s3.put_object(
Bucket=params.bucket,
Key=params.key,
Body=bundle
)
else:
return self._multipart_upload_to_s3(
params,
bundle,
size_remaining
)
def _bundle_size(self, bundle):
bundle.seek(0, 2)
size = bundle.tell()
bundle.seek(0)
return size
def _multipart_upload_to_s3(self, params, bundle, size_remaining):
create_response = self.s3.create_multipart_upload(
Bucket=params.bucket,
Key=params.key
)
upload_id = create_response['UploadId']
try:
part_num = 1
multipart_list = []
bundle.seek(0)
while size_remaining > 0:
data = bundle.read(MULTIPART_LIMIT)
upload_response = self.s3.upload_part(
Bucket=params.bucket,
Key=params.key,
UploadId=upload_id,
PartNumber=part_num,
Body=six.BytesIO(data)
)
multipart_list.append({
'PartNumber': part_num,
'ETag': upload_response['ETag']
})
part_num += 1
size_remaining -= len(data)
return self.s3.complete_multipart_upload(
Bucket=params.bucket,
Key=params.key,
UploadId=upload_id,
MultipartUpload={'Parts': multipart_list}
)
except ClientError as e:
self.s3.abort_multipart_upload(
Bucket=params.bucket,
Key=params.key,
UploadId=upload_id
)
raise e
def _register_revision(self, params):
revision = {
'revisionType': 'S3',
's3Location': {
'bucket': params.bucket,
'key': params.key,
'bundleType': 'zip',
'eTag': params.eTag
}
}
if 'version' in params:
revision['s3Location']['version'] = params.version
self.codedeploy.register_application_revision(
applicationName=params.application_name,
revision=revision,
description=params.description
)
| .. | |||||
| __pycache__ | |||||
| __init__.py | |||||
| codedeploy.py | |||||
| deregister.py | |||||
| install.py | |||||
| locationargs.py | |||||
| push.py | |||||
| register.py | |||||
| systems.py | |||||
| uninstall.py | |||||
| utils.py |