async def create_campaign(
self,
name: "capo_connectcampaigns.types.campaign_name.CampaignName",
connect_instance_id: "capo_connectcampaigns.types.instance_id.InstanceId",
dialer_config: "capo_connectcampaigns.types.dialer_config.DialerConfig",
outbound_call_config: "capo_connectcampaigns.types.outbound_call_config.OutboundCallConfig",
*,
config_overrides: Optional[AsyncConnectCampaignsClientConfig] = None,
tags: Optional["capo_connectcampaigns.types.tag_map.TagMap"] = None,
) -> "capo_connectcampaigns.types.create_campaign_response.CreateCampaignResponse":
"""Creates a campaign for the specified Amazon Connect account. This API is idempotent.
Raises:
capo_connectcampaigns.errors.access_denied_exception.AccessDeniedException: You do not have sufficient access to perform this action.
capo_connectcampaigns.errors.conflict_exception.ConflictException: The request could not be processed because of conflict in the current state of the resource.
capo_connectcampaigns.errors.internal_server_exception.InternalServerException: Request processing failed because of an error or failure with the service.
capo_connectcampaigns.errors.resource_not_found_exception.ResourceNotFoundException: The specified resource was not found.
capo_connectcampaigns.errors.service_quota_exceeded_exception.ServiceQuotaExceededException: Request would cause a service quota to be exceeded.
capo_connectcampaigns.errors.throttling_exception.ThrottlingException: The request was denied due to request throttling.
capo_connectcampaigns.errors.validation_exception.ValidationException: The input fails to satisfy the constraints specified by an AWS service.
capo_connectcampaigns.errors.UnknownServiceError: The service returned an error code this client does not model.
"""
async def _handler(
req: "AsyncOperationRequest[capo_connectcampaigns.types.create_campaign_request.CreateCampaignRequest]",
) -> AsyncOperationResponse[
"capo_connectcampaigns.types.create_campaign_response.CreateCampaignResponse"
]:
import capo_connectcampaigns._operations.amazon_connect_campaign_service.create_campaign
(
output,
http_response,
) = await capo_connectcampaigns._operations.amazon_connect_campaign_service.create_campaign.async_create_campaign(
req.options, req.input
)
return AsyncOperationResponse(output=output, response=http_response)
interceptors_, options_ = self.operation_options(
config_overrides, OperationLogging("CreateCampaign")
)
input_: capo_connectcampaigns.types.create_campaign_request.CreateCampaignRequest = {
"name": name,
"connect_instance_id": connect_instance_id,
"dialer_config": dialer_config,
"outbound_call_config": outbound_call_config,
}
if tags is not None:
input_["tags"] = tags
response = await aexecute_pipeline(
AsyncOperationRequest(input=input_, options=options_),
handler=_handler,
interceptors=list(interceptors_),
)
await response.response.aclose()
return response.output