Table of Contents
A low-level client representing AmazonMQ:
import boto3
client = boto3.client('mq')
These are the available methods:
Check if an operation can be paginated.
Creates a broker. Note: This API is asynchronous.
See also: AWS API Documentation
Request Syntax
response = client.create_broker(
AutoMinorVersionUpgrade=True|False,
BrokerName='string',
Configuration={
'Id': 'string',
'Revision': 123
},
CreatorRequestId='string',
DeploymentMode='SINGLE_INSTANCE'|'ACTIVE_STANDBY_MULTI_AZ',
EncryptionOptions={
'KmsKeyId': 'string',
'UseAwsOwnedKey': True|False
},
EngineType='ACTIVEMQ',
EngineVersion='string',
HostInstanceType='string',
Logs={
'Audit': True|False,
'General': True|False
},
MaintenanceWindowStartTime={
'DayOfWeek': 'MONDAY'|'TUESDAY'|'WEDNESDAY'|'THURSDAY'|'FRIDAY'|'SATURDAY'|'SUNDAY',
'TimeOfDay': 'string',
'TimeZone': 'string'
},
PubliclyAccessible=True|False,
SecurityGroups=[
'string',
],
StorageType='EBS'|'EFS',
SubnetIds=[
'string',
],
Tags={
'string': 'string'
},
Users=[
{
'ConsoleAccess': True|False,
'Groups': [
'string',
],
'Password': 'string',
'Username': 'string'
},
]
)
A list of information about the configuration.
Encryption options for the broker.
Enables Amazon CloudWatch logging for brokers.
The parameters that determine the WeeklyStartTime.
The list of security groups (1 minimum, 5 maximum) that authorizes connections to brokers.
The list of groups (2 maximum) that define which subnets and IP ranges the broker can use from different Availability Zones. A SINGLE_INSTANCE deployment requires one subnet (for example, the default subnet). An ACTIVE_STANDBY_MULTI_AZ deployment requires two subnets.
Create tags when creating the broker.
Required. The list of ActiveMQ users (persons or applications) who can access queues and topics. This value can contain only alphanumeric characters, dashes, periods, underscores, and tildes (- . _ ~). This value must be 2-100 characters long.
dict
Response Syntax
{
'BrokerArn': 'string',
'BrokerId': 'string'
}
Response Structure
Creates a new configuration for the specified configuration name. Amazon MQ uses the default configuration (the engine type and version).
See also: AWS API Documentation
Request Syntax
response = client.create_configuration(
EngineType='ACTIVEMQ',
EngineVersion='string',
Name='string',
Tags={
'string': 'string'
}
)
Create tags when creating the configuration.
dict
Response Syntax
{
'Arn': 'string',
'Created': datetime(2015, 1, 1),
'Id': 'string',
'LatestRevision': {
'Created': datetime(2015, 1, 1),
'Description': 'string',
'Revision': 123
},
'Name': 'string'
}
Response Structure
Add a tag to a resource.
See also: AWS API Documentation
Request Syntax
response = client.create_tags(
ResourceArn='string',
Tags={
'string': 'string'
}
)
The key-value pair for the resource tag.
None
Creates an ActiveMQ user.
See also: AWS API Documentation
Request Syntax
response = client.create_user(
BrokerId='string',
ConsoleAccess=True|False,
Groups=[
'string',
],
Password='string',
Username='string'
)
The list of groups (20 maximum) to which the ActiveMQ user belongs. This value can contain only alphanumeric characters, dashes, periods, underscores, and tildes (- . _ ~). This value must be 2-100 characters long.
dict
Response Syntax
{}
Response Structure
Deletes a broker. Note: This API is asynchronous.
See also: AWS API Documentation
Request Syntax
response = client.delete_broker(
BrokerId='string'
)
{
'BrokerId': 'string'
}
Response Structure
Removes a tag from a resource.
See also: AWS API Documentation
Request Syntax
response = client.delete_tags(
ResourceArn='string',
TagKeys=[
'string',
]
)
[REQUIRED] An array of tag keys to delete
None
Deletes an ActiveMQ user.
See also: AWS API Documentation
Request Syntax
response = client.delete_user(
BrokerId='string',
Username='string'
)
dict
Response Syntax
{}
Response Structure
Returns information about the specified broker.
See also: AWS API Documentation
Request Syntax
response = client.describe_broker(
BrokerId='string'
)
{
'AutoMinorVersionUpgrade': True|False,
'BrokerArn': 'string',
'BrokerId': 'string',
'BrokerInstances': [
{
'ConsoleURL': 'string',
'Endpoints': [
'string',
],
'IpAddress': 'string'
},
],
'BrokerName': 'string',
'BrokerState': 'CREATION_IN_PROGRESS'|'CREATION_FAILED'|'DELETION_IN_PROGRESS'|'RUNNING'|'REBOOT_IN_PROGRESS',
'Configurations': {
'Current': {
'Id': 'string',
'Revision': 123
},
'History': [
{
'Id': 'string',
'Revision': 123
},
],
'Pending': {
'Id': 'string',
'Revision': 123
}
},
'Created': datetime(2015, 1, 1),
'DeploymentMode': 'SINGLE_INSTANCE'|'ACTIVE_STANDBY_MULTI_AZ',
'EncryptionOptions': {
'KmsKeyId': 'string',
'UseAwsOwnedKey': True|False
},
'EngineType': 'ACTIVEMQ',
'EngineVersion': 'string',
'HostInstanceType': 'string',
'Logs': {
'Audit': True|False,
'AuditLogGroup': 'string',
'General': True|False,
'GeneralLogGroup': 'string',
'Pending': {
'Audit': True|False,
'General': True|False
}
},
'MaintenanceWindowStartTime': {
'DayOfWeek': 'MONDAY'|'TUESDAY'|'WEDNESDAY'|'THURSDAY'|'FRIDAY'|'SATURDAY'|'SUNDAY',
'TimeOfDay': 'string',
'TimeZone': 'string'
},
'PendingEngineVersion': 'string',
'PendingHostInstanceType': 'string',
'PendingSecurityGroups': [
'string',
],
'PubliclyAccessible': True|False,
'SecurityGroups': [
'string',
],
'StorageType': 'EBS'|'EFS',
'SubnetIds': [
'string',
],
'Tags': {
'string': 'string'
},
'Users': [
{
'PendingChange': 'CREATE'|'UPDATE'|'DELETE',
'Username': 'string'
},
]
}
Response Structure
Describe available engine types and versions.
See also: AWS API Documentation
Request Syntax
response = client.describe_broker_engine_types(
EngineType='string',
MaxResults=123,
NextToken='string'
)
dict
Response Syntax
{
'BrokerEngineTypes': [
{
'EngineType': 'ACTIVEMQ',
'EngineVersions': [
{
'Name': 'string'
},
]
},
],
'MaxResults': 123,
'NextToken': 'string'
}
Response Structure
Describe available broker instance options.
See also: AWS API Documentation
Request Syntax
response = client.describe_broker_instance_options(
EngineType='string',
HostInstanceType='string',
MaxResults=123,
NextToken='string',
StorageType='string'
)
dict
Response Syntax
{
'BrokerInstanceOptions': [
{
'AvailabilityZones': [
{
'Name': 'string'
},
],
'EngineType': 'ACTIVEMQ',
'HostInstanceType': 'string',
'StorageType': 'EBS'|'EFS',
'SupportedDeploymentModes': [
'SINGLE_INSTANCE'|'ACTIVE_STANDBY_MULTI_AZ',
],
'SupportedEngineVersions': [
'string',
]
},
],
'MaxResults': 123,
'NextToken': 'string'
}
Response Structure
Returns information about the specified configuration.
See also: AWS API Documentation
Request Syntax
response = client.describe_configuration(
ConfigurationId='string'
)
{
'Arn': 'string',
'Created': datetime(2015, 1, 1),
'Description': 'string',
'EngineType': 'ACTIVEMQ',
'EngineVersion': 'string',
'Id': 'string',
'LatestRevision': {
'Created': datetime(2015, 1, 1),
'Description': 'string',
'Revision': 123
},
'Name': 'string',
'Tags': {
'string': 'string'
}
}
Response Structure
Returns the specified configuration revision for the specified configuration.
See also: AWS API Documentation
Request Syntax
response = client.describe_configuration_revision(
ConfigurationId='string',
ConfigurationRevision='string'
)
dict
Response Syntax
{
'ConfigurationId': 'string',
'Created': datetime(2015, 1, 1),
'Data': 'string',
'Description': 'string'
}
Response Structure
Returns information about an ActiveMQ user.
See also: AWS API Documentation
Request Syntax
response = client.describe_user(
BrokerId='string',
Username='string'
)
dict
Response Syntax
{
'BrokerId': 'string',
'ConsoleAccess': True|False,
'Groups': [
'string',
],
'Pending': {
'ConsoleAccess': True|False,
'Groups': [
'string',
],
'PendingChange': 'CREATE'|'UPDATE'|'DELETE'
},
'Username': 'string'
}
Response Structure
Generate a presigned url given a client, its method, and arguments
The presigned url
Create a paginator for an operation.
Returns an object that can wait for some condition.
Returns a list of all brokers.
See also: AWS API Documentation
Request Syntax
response = client.list_brokers(
MaxResults=123,
NextToken='string'
)
dict
Response Syntax
{
'BrokerSummaries': [
{
'BrokerArn': 'string',
'BrokerId': 'string',
'BrokerName': 'string',
'BrokerState': 'CREATION_IN_PROGRESS'|'CREATION_FAILED'|'DELETION_IN_PROGRESS'|'RUNNING'|'REBOOT_IN_PROGRESS',
'Created': datetime(2015, 1, 1),
'DeploymentMode': 'SINGLE_INSTANCE'|'ACTIVE_STANDBY_MULTI_AZ',
'HostInstanceType': 'string'
},
],
'NextToken': 'string'
}
Response Structure
Returns a list of all revisions for the specified configuration.
See also: AWS API Documentation
Request Syntax
response = client.list_configuration_revisions(
ConfigurationId='string',
MaxResults=123,
NextToken='string'
)
dict
Response Syntax
{
'ConfigurationId': 'string',
'MaxResults': 123,
'NextToken': 'string',
'Revisions': [
{
'Created': datetime(2015, 1, 1),
'Description': 'string',
'Revision': 123
},
]
}
Response Structure
Returns a list of all configurations.
See also: AWS API Documentation
Request Syntax
response = client.list_configurations(
MaxResults=123,
NextToken='string'
)
dict
Response Syntax
{
'Configurations': [
{
'Arn': 'string',
'Created': datetime(2015, 1, 1),
'Description': 'string',
'EngineType': 'ACTIVEMQ',
'EngineVersion': 'string',
'Id': 'string',
'LatestRevision': {
'Created': datetime(2015, 1, 1),
'Description': 'string',
'Revision': 123
},
'Name': 'string',
'Tags': {
'string': 'string'
}
},
],
'MaxResults': 123,
'NextToken': 'string'
}
Response Structure
Lists tags for a resource.
See also: AWS API Documentation
Request Syntax
response = client.list_tags(
ResourceArn='string'
)
{
'Tags': {
'string': 'string'
}
}
Response Structure
Returns a list of all ActiveMQ users.
See also: AWS API Documentation
Request Syntax
response = client.list_users(
BrokerId='string',
MaxResults=123,
NextToken='string'
)
dict
Response Syntax
{
'BrokerId': 'string',
'MaxResults': 123,
'NextToken': 'string',
'Users': [
{
'PendingChange': 'CREATE'|'UPDATE'|'DELETE',
'Username': 'string'
},
]
}
Response Structure
Reboots a broker. Note: This API is asynchronous.
See also: AWS API Documentation
Request Syntax
response = client.reboot_broker(
BrokerId='string'
)
{}
Response Structure
Adds a pending configuration change to a broker.
See also: AWS API Documentation
Request Syntax
response = client.update_broker(
AutoMinorVersionUpgrade=True|False,
BrokerId='string',
Configuration={
'Id': 'string',
'Revision': 123
},
EngineVersion='string',
HostInstanceType='string',
Logs={
'Audit': True|False,
'General': True|False
},
SecurityGroups=[
'string',
]
)
A list of information about the configuration.
Enables Amazon CloudWatch logging for brokers.
The list of security groups (1 minimum, 5 maximum) that authorizes connections to brokers.
dict
Response Syntax
{
'AutoMinorVersionUpgrade': True|False,
'BrokerId': 'string',
'Configuration': {
'Id': 'string',
'Revision': 123
},
'EngineVersion': 'string',
'HostInstanceType': 'string',
'Logs': {
'Audit': True|False,
'General': True|False
},
'SecurityGroups': [
'string',
]
}
Response Structure
Updates the specified configuration.
See also: AWS API Documentation
Request Syntax
response = client.update_configuration(
ConfigurationId='string',
Data='string',
Description='string'
)
dict
Response Syntax
{
'Arn': 'string',
'Created': datetime(2015, 1, 1),
'Id': 'string',
'LatestRevision': {
'Created': datetime(2015, 1, 1),
'Description': 'string',
'Revision': 123
},
'Name': 'string',
'Warnings': [
{
'AttributeName': 'string',
'ElementName': 'string',
'Reason': 'DISALLOWED_ELEMENT_REMOVED'|'DISALLOWED_ATTRIBUTE_REMOVED'|'INVALID_ATTRIBUTE_VALUE_REMOVED'
},
]
}
Response Structure
Updates the information for an ActiveMQ user.
See also: AWS API Documentation
Request Syntax
response = client.update_user(
BrokerId='string',
ConsoleAccess=True|False,
Groups=[
'string',
],
Password='string',
Username='string'
)
The list of groups (20 maximum) to which the ActiveMQ user belongs. This value can contain only alphanumeric characters, dashes, periods, underscores, and tildes (- . _ ~). This value must be 2-100 characters long.
dict
Response Syntax
{}
Response Structure
The available paginators are:
paginator = client.get_paginator('list_brokers')
Creates an iterator that will paginate through responses from MQ.Client.list_brokers().
See also: AWS API Documentation
Request Syntax
response_iterator = paginator.paginate(
PaginationConfig={
'MaxItems': 123,
'PageSize': 123,
'StartingToken': 'string'
}
)
A dictionary that provides parameters to control pagination.
The total number of items to return. If the total number of items available is more than the value specified in max-items then a NextToken will be provided in the output that you can use to resume pagination.
The size of each page.
A token to specify where to start paginating. This is the NextToken from a previous response.
{
'BrokerSummaries': [
{
'BrokerArn': 'string',
'BrokerId': 'string',
'BrokerName': 'string',
'BrokerState': 'CREATION_IN_PROGRESS'|'CREATION_FAILED'|'DELETION_IN_PROGRESS'|'RUNNING'|'REBOOT_IN_PROGRESS',
'Created': datetime(2015, 1, 1),
'DeploymentMode': 'SINGLE_INSTANCE'|'ACTIVE_STANDBY_MULTI_AZ',
'HostInstanceType': 'string'
},
],
}
Response Structure