...
| Code Block |
|---|
|
#!/usr/bin/python3
import boto3
from botocore.client import Config
access_key_id = 'xx' # stored in Morpheus Cypher
secret_access_key = 'xx' # stored in Morpheus Cypher
ceph_endpoint = '<ceph endpoint>'
region_name = 'default' # required by boto3, any value works
endpoint = "http://vm-name.tenancy-name.s/f.ewcloud.host" # your own http endpoint
topic_name = 'example-topic'
client = boto3.client('sns',
endpoint_url= ceph_endpoint,
aws_access_key_id=access_key_id,
aws_secret_access_key=secret_access_key,
region_name=region_name,
config=Config(signature_version='s3'))
client.create_topic(Name=topic_name, Attributes={'persistent': 'True', 'push-endpoint': endpoint}) |
...
| Code Block |
|---|
|
#!/usr/bin/python3
import boto3
from botocore.client import Config
access_key_id = 'xx' # stored in Morpheus Cypher
secret_access_key = 'xx' # stored in Morpheus Cypher
ceph_endpoint = '<ceph endpoint>'
region_name = 'default' # required by boto3, any value works
sns = boto3.client('sns',
region_name=region_name,
endpoint_url= ceph_endpoint,
aws_access_key_id=access_key_id,
aws_secret_access_key=secret_access_key,
config=Config(signature_version='s3'))
response = sns.list_topics()
# Print the Topic ARNs
print('All topics:')
for topic in response['Topics']:
print(' -'+topic['TopicArn'])
|
...
| Code Block |
|---|
|
#!/usr/bin/python3
import boto3
access_key_id='xx' # from Morpheus Cypher
secret_access_key='xx' # from Morpheus Cypher
ceph_endpoint = "<ceph endpoint>"
region = 'default' # required by boto3, any value works
arn = 'arn:aws:sns:default::example-topic'
sns = boto3.client('sns',
region_name=region,
endpoint_url=ceph_endpoint ,
aws_access_key_id=access_key_id,
aws_secret_access_key=secret_access_key,
config=Config(signature_version='s3'))
# Delete the SNS topic
response = sns.delete_topic(TopicArn=arn)
|
Delete bucket notification configuration
The notifications configuration on a certain bucket could be deleted as follows by applying an empty configuration:
| Code Block |
|---|
|
#!/usr/bin/python3
import boto3
access_key_id='xxx' # from Morpheus Cypher
secret_access_key='xxx' # from Morpheus Cypher
ceph_endpoint = "<ceph endpoint>"
region = 'default' # required by boto3, any value works
bucket_name = "<bucket name>"
s3 = boto3.client('s3',
endpoint_url=ceph_endpoint ,
aws_access_key_id=access_key_id,
aws_secret_access_key=secret_access_key)
# Clean notification configuration
response = s3.put_bucket_notification_configuration(
Bucket=bucket_name,
NotificationConfiguration={})
|