1. Packages
  2. Tencentcloud Provider
  3. API Docs
  4. EbEventConnector
tencentcloud 1.81.182 published on Monday, Apr 14, 2025 by tencentcloudstack

tencentcloud.EbEventConnector

Explore with Pulumi AI

Provides a resource to create a eb event_connector

NOTE: When the type is apigw, the import function is not supported.

Example Usage

Create ckafka event connector

import * as pulumi from "@pulumi/pulumi";
import * as tencentcloud from "@pulumi/tencentcloud";

const fooUserInfo = tencentcloud.getUserInfo({});
const fooEbEventBus = new tencentcloud.EbEventBus("fooEbEventBus", {
    eventBusName: "tf-event_bus",
    description: "event bus desc",
    enableStore: false,
    saveDays: 1,
    tags: {
        createdBy: "terraform",
    },
});
const kafkaInstance = new tencentcloud.CkafkaInstance("kafkaInstance", {
    instanceName: "ckafka-instance-maz-tf-test",
    zoneId: 100003,
    multiZoneFlag: true,
    zoneIds: [
        100003,
        100006,
    ],
    period: 1,
    vpcId: _var.vpc_id,
    subnetId: _var.subnet_id,
    msgRetentionTime: 1300,
    renewFlag: 0,
    kafkaVersion: "1.1.1",
    diskSize: 500,
    diskType: "CLOUD_BASIC",
    config: {
        autoCreateTopicEnable: true,
        defaultNumPartitions: 3,
        defaultReplicationFactor: 3,
    },
    dynamicRetentionConfig: {
        enable: 1,
    },
});
const ckafkaId = kafkaInstance.ckafkaInstanceId;
const uin = fooUserInfo.then(fooUserInfo => fooUserInfo.ownerUin);
const eventConnector = new tencentcloud.EbEventConnector("eventConnector", {
    eventBusId: fooEbEventBus.ebEventBusId,
    connectionName: "tf-event-connector",
    description: "event connector desc1",
    enable: true,
    type: "ckafka",
    connectionDescription: {
        resourceDescription: pulumi.all([uin, uin, ckafkaId]).apply(([uin, uin1, ckafkaId]) => `qcs::ckafka:ap-guangzhou:uin/${uin}:ckafkaId/uin/${uin1}/${ckafkaId}`),
        ckafkaParams: {
            offset: "latest",
            topicName: "dasdasd",
        },
    },
});
Copy
import pulumi
import pulumi_tencentcloud as tencentcloud

foo_user_info = tencentcloud.get_user_info()
foo_eb_event_bus = tencentcloud.EbEventBus("fooEbEventBus",
    event_bus_name="tf-event_bus",
    description="event bus desc",
    enable_store=False,
    save_days=1,
    tags={
        "createdBy": "terraform",
    })
kafka_instance = tencentcloud.CkafkaInstance("kafkaInstance",
    instance_name="ckafka-instance-maz-tf-test",
    zone_id=100003,
    multi_zone_flag=True,
    zone_ids=[
        100003,
        100006,
    ],
    period=1,
    vpc_id=var["vpc_id"],
    subnet_id=var["subnet_id"],
    msg_retention_time=1300,
    renew_flag=0,
    kafka_version="1.1.1",
    disk_size=500,
    disk_type="CLOUD_BASIC",
    config={
        "auto_create_topic_enable": True,
        "default_num_partitions": 3,
        "default_replication_factor": 3,
    },
    dynamic_retention_config={
        "enable": 1,
    })
ckafka_id = kafka_instance.ckafka_instance_id
uin = foo_user_info.owner_uin
event_connector = tencentcloud.EbEventConnector("eventConnector",
    event_bus_id=foo_eb_event_bus.eb_event_bus_id,
    connection_name="tf-event-connector",
    description="event connector desc1",
    enable=True,
    type="ckafka",
    connection_description={
        "resource_description": ckafka_id.apply(lambda ckafka_id: f"qcs::ckafka:ap-guangzhou:uin/{uin}:ckafkaId/uin/{uin}/{ckafka_id}"),
        "ckafka_params": {
            "offset": "latest",
            "topic_name": "dasdasd",
        },
    })
Copy
package main

import (
	"fmt"

	"github.com/pulumi/pulumi-terraform-provider/sdks/go/tencentcloud/tencentcloud"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		fooUserInfo, err := tencentcloud.GetUserInfo(ctx, &tencentcloud.GetUserInfoArgs{}, nil)
		if err != nil {
			return err
		}
		fooEbEventBus, err := tencentcloud.NewEbEventBus(ctx, "fooEbEventBus", &tencentcloud.EbEventBusArgs{
			EventBusName: pulumi.String("tf-event_bus"),
			Description:  pulumi.String("event bus desc"),
			EnableStore:  pulumi.Bool(false),
			SaveDays:     pulumi.Float64(1),
			Tags: pulumi.StringMap{
				"createdBy": pulumi.String("terraform"),
			},
		})
		if err != nil {
			return err
		}
		kafkaInstance, err := tencentcloud.NewCkafkaInstance(ctx, "kafkaInstance", &tencentcloud.CkafkaInstanceArgs{
			InstanceName:  pulumi.String("ckafka-instance-maz-tf-test"),
			ZoneId:        pulumi.Float64(100003),
			MultiZoneFlag: pulumi.Bool(true),
			ZoneIds: pulumi.Float64Array{
				pulumi.Float64(100003),
				pulumi.Float64(100006),
			},
			Period:           pulumi.Float64(1),
			VpcId:            pulumi.Any(_var.Vpc_id),
			SubnetId:         pulumi.Any(_var.Subnet_id),
			MsgRetentionTime: pulumi.Float64(1300),
			RenewFlag:        pulumi.Float64(0),
			KafkaVersion:     pulumi.String("1.1.1"),
			DiskSize:         pulumi.Float64(500),
			DiskType:         pulumi.String("CLOUD_BASIC"),
			Config: &tencentcloud.CkafkaInstanceConfigArgs{
				AutoCreateTopicEnable:    pulumi.Bool(true),
				DefaultNumPartitions:     pulumi.Float64(3),
				DefaultReplicationFactor: pulumi.Float64(3),
			},
			DynamicRetentionConfig: &tencentcloud.CkafkaInstanceDynamicRetentionConfigArgs{
				Enable: pulumi.Float64(1),
			},
		})
		if err != nil {
			return err
		}
		ckafkaId := kafkaInstance.CkafkaInstanceId
		uin := fooUserInfo.OwnerUin
		_, err = tencentcloud.NewEbEventConnector(ctx, "eventConnector", &tencentcloud.EbEventConnectorArgs{
			EventBusId:     fooEbEventBus.EbEventBusId,
			ConnectionName: pulumi.String("tf-event-connector"),
			Description:    pulumi.String("event connector desc1"),
			Enable:         pulumi.Bool(true),
			Type:           pulumi.String("ckafka"),
			ConnectionDescription: &tencentcloud.EbEventConnectorConnectionDescriptionArgs{
				ResourceDescription: ckafkaId.ApplyT(func(ckafkaId string) (string, error) {
					return fmt.Sprintf("qcs::ckafka:ap-guangzhou:uin/%v:ckafkaId/uin/%v/%v", uin, uin, ckafkaId), nil
				}).(pulumi.StringOutput),
				CkafkaParams: &tencentcloud.EbEventConnectorConnectionDescriptionCkafkaParamsArgs{
					Offset:    pulumi.String("latest"),
					TopicName: pulumi.String("dasdasd"),
				},
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}
Copy
using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Tencentcloud = Pulumi.Tencentcloud;

return await Deployment.RunAsync(() => 
{
    var fooUserInfo = Tencentcloud.GetUserInfo.Invoke();

    var fooEbEventBus = new Tencentcloud.EbEventBus("fooEbEventBus", new()
    {
        EventBusName = "tf-event_bus",
        Description = "event bus desc",
        EnableStore = false,
        SaveDays = 1,
        Tags = 
        {
            { "createdBy", "terraform" },
        },
    });

    var kafkaInstance = new Tencentcloud.CkafkaInstance("kafkaInstance", new()
    {
        InstanceName = "ckafka-instance-maz-tf-test",
        ZoneId = 100003,
        MultiZoneFlag = true,
        ZoneIds = new[]
        {
            100003,
            100006,
        },
        Period = 1,
        VpcId = @var.Vpc_id,
        SubnetId = @var.Subnet_id,
        MsgRetentionTime = 1300,
        RenewFlag = 0,
        KafkaVersion = "1.1.1",
        DiskSize = 500,
        DiskType = "CLOUD_BASIC",
        Config = new Tencentcloud.Inputs.CkafkaInstanceConfigArgs
        {
            AutoCreateTopicEnable = true,
            DefaultNumPartitions = 3,
            DefaultReplicationFactor = 3,
        },
        DynamicRetentionConfig = new Tencentcloud.Inputs.CkafkaInstanceDynamicRetentionConfigArgs
        {
            Enable = 1,
        },
    });

    var ckafkaId = kafkaInstance.CkafkaInstanceId;

    var uin = fooUserInfo.Apply(getUserInfoResult => getUserInfoResult.OwnerUin);

    var eventConnector = new Tencentcloud.EbEventConnector("eventConnector", new()
    {
        EventBusId = fooEbEventBus.EbEventBusId,
        ConnectionName = "tf-event-connector",
        Description = "event connector desc1",
        Enable = true,
        Type = "ckafka",
        ConnectionDescription = new Tencentcloud.Inputs.EbEventConnectorConnectionDescriptionArgs
        {
            ResourceDescription = Output.Tuple(uin, uin, ckafkaId).Apply(values =>
            {
                var uin = values.Item1;
                var uin1 = values.Item2;
                var ckafkaId = values.Item3;
                return $"qcs::ckafka:ap-guangzhou:uin/{uin}:ckafkaId/uin/{uin1}/{ckafkaId}";
            }),
            CkafkaParams = new Tencentcloud.Inputs.EbEventConnectorConnectionDescriptionCkafkaParamsArgs
            {
                Offset = "latest",
                TopicName = "dasdasd",
            },
        },
    });

});
Copy
package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.tencentcloud.TencentcloudFunctions;
import com.pulumi.tencentcloud.inputs.GetUserInfoArgs;
import com.pulumi.tencentcloud.EbEventBus;
import com.pulumi.tencentcloud.EbEventBusArgs;
import com.pulumi.tencentcloud.CkafkaInstance;
import com.pulumi.tencentcloud.CkafkaInstanceArgs;
import com.pulumi.tencentcloud.inputs.CkafkaInstanceConfigArgs;
import com.pulumi.tencentcloud.inputs.CkafkaInstanceDynamicRetentionConfigArgs;
import com.pulumi.tencentcloud.EbEventConnector;
import com.pulumi.tencentcloud.EbEventConnectorArgs;
import com.pulumi.tencentcloud.inputs.EbEventConnectorConnectionDescriptionArgs;
import com.pulumi.tencentcloud.inputs.EbEventConnectorConnectionDescriptionCkafkaParamsArgs;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;

public class App {
    public static void main(String[] args) {
        Pulumi.run(App::stack);
    }

    public static void stack(Context ctx) {
        final var fooUserInfo = TencentcloudFunctions.getUserInfo();

        var fooEbEventBus = new EbEventBus("fooEbEventBus", EbEventBusArgs.builder()
            .eventBusName("tf-event_bus")
            .description("event bus desc")
            .enableStore(false)
            .saveDays(1)
            .tags(Map.of("createdBy", "terraform"))
            .build());

        var kafkaInstance = new CkafkaInstance("kafkaInstance", CkafkaInstanceArgs.builder()
            .instanceName("ckafka-instance-maz-tf-test")
            .zoneId(100003)
            .multiZoneFlag(true)
            .zoneIds(            
                100003,
                100006)
            .period(1)
            .vpcId(var_.vpc_id())
            .subnetId(var_.subnet_id())
            .msgRetentionTime(1300)
            .renewFlag(0)
            .kafkaVersion("1.1.1")
            .diskSize(500)
            .diskType("CLOUD_BASIC")
            .config(CkafkaInstanceConfigArgs.builder()
                .autoCreateTopicEnable(true)
                .defaultNumPartitions(3)
                .defaultReplicationFactor(3)
                .build())
            .dynamicRetentionConfig(CkafkaInstanceDynamicRetentionConfigArgs.builder()
                .enable(1)
                .build())
            .build());

        final var ckafkaId = kafkaInstance.ckafkaInstanceId();

        final var uin = fooUserInfo.applyValue(getUserInfoResult -> getUserInfoResult.ownerUin());

        var eventConnector = new EbEventConnector("eventConnector", EbEventConnectorArgs.builder()
            .eventBusId(fooEbEventBus.ebEventBusId())
            .connectionName("tf-event-connector")
            .description("event connector desc1")
            .enable(true)
            .type("ckafka")
            .connectionDescription(EbEventConnectorConnectionDescriptionArgs.builder()
                .resourceDescription(ckafkaId.applyValue(ckafkaId -> String.format("qcs::ckafka:ap-guangzhou:uin/%s:ckafkaId/uin/%s/%s", uin,uin,ckafkaId)))
                .ckafkaParams(EbEventConnectorConnectionDescriptionCkafkaParamsArgs.builder()
                    .offset("latest")
                    .topicName("dasdasd")
                    .build())
                .build())
            .build());

    }
}
Copy
resources:
  fooEbEventBus:
    type: tencentcloud:EbEventBus
    properties:
      eventBusName: tf-event_bus
      description: event bus desc
      enableStore: false
      saveDays: 1
      tags:
        createdBy: terraform
  kafkaInstance:
    type: tencentcloud:CkafkaInstance
    properties:
      instanceName: ckafka-instance-maz-tf-test
      zoneId: 100003
      multiZoneFlag: true
      zoneIds:
        - 100003
        - 100006
      period: 1
      vpcId: ${var.vpc_id}
      subnetId: ${var.subnet_id}
      msgRetentionTime: 1300
      renewFlag: 0
      kafkaVersion: 1.1.1
      diskSize: 500
      diskType: CLOUD_BASIC
      config:
        autoCreateTopicEnable: true
        defaultNumPartitions: 3
        defaultReplicationFactor: 3
      dynamicRetentionConfig:
        enable: 1
  eventConnector:
    type: tencentcloud:EbEventConnector
    properties:
      eventBusId: ${fooEbEventBus.ebEventBusId}
      connectionName: tf-event-connector
      description: event connector desc1
      enable: true
      type: ckafka
      connectionDescription:
        resourceDescription: qcs::ckafka:ap-guangzhou:uin/${uin}:ckafkaId/uin/${uin}/${ckafkaId}
        ckafkaParams:
          offset: latest
          topicName: dasdasd
variables:
  fooUserInfo:
    fn::invoke:
      function: tencentcloud:getUserInfo
      arguments: {}
  ckafkaId: ${kafkaInstance.ckafkaInstanceId}
  uin: ${fooUserInfo.ownerUin}
Copy

Create api_gateway event connector

import * as pulumi from "@pulumi/pulumi";
import * as tencentcloud from "@pulumi/tencentcloud";

const fooUserInfo = tencentcloud.getUserInfo({});
const fooEbEventBus = new tencentcloud.EbEventBus("fooEbEventBus", {
    eventBusName: "tf-event_bus",
    description: "event bus desc",
    enableStore: false,
    saveDays: 1,
    tags: {
        createdBy: "terraform",
    },
});
const service = new tencentcloud.ApiGatewayService("service", {
    serviceName: "tf-eb-service",
    protocol: "http&https",
    serviceDesc: "your nice service",
    netTypes: [
        "INNER",
        "OUTER",
    ],
    ipVersion: "IPv4",
});
const uin = fooUserInfo.then(fooUserInfo => fooUserInfo.ownerUin);
const serviceId = service.apiGatewayServiceId;
const eventConnector = new tencentcloud.EbEventConnector("eventConnector", {
    eventBusId: fooEbEventBus.ebEventBusId,
    connectionName: "tf-event-connector",
    description: "event connector desc1",
    enable: false,
    type: "apigw",
    connectionDescription: {
        resourceDescription: pulumi.all([uin, serviceId]).apply(([uin, serviceId]) => `qcs::apigw:ap-guangzhou:uin/${uin}:serviceid/${serviceId}`),
        apiGwParams: {
            protocol: "HTTP",
            method: "GET",
        },
    },
});
Copy
import pulumi
import pulumi_tencentcloud as tencentcloud

foo_user_info = tencentcloud.get_user_info()
foo_eb_event_bus = tencentcloud.EbEventBus("fooEbEventBus",
    event_bus_name="tf-event_bus",
    description="event bus desc",
    enable_store=False,
    save_days=1,
    tags={
        "createdBy": "terraform",
    })
service = tencentcloud.ApiGatewayService("service",
    service_name="tf-eb-service",
    protocol="http&https",
    service_desc="your nice service",
    net_types=[
        "INNER",
        "OUTER",
    ],
    ip_version="IPv4")
uin = foo_user_info.owner_uin
service_id = service.api_gateway_service_id
event_connector = tencentcloud.EbEventConnector("eventConnector",
    event_bus_id=foo_eb_event_bus.eb_event_bus_id,
    connection_name="tf-event-connector",
    description="event connector desc1",
    enable=False,
    type="apigw",
    connection_description={
        "resource_description": service_id.apply(lambda service_id: f"qcs::apigw:ap-guangzhou:uin/{uin}:serviceid/{service_id}"),
        "api_gw_params": {
            "protocol": "HTTP",
            "method": "GET",
        },
    })
Copy
package main

import (
	"fmt"

	"github.com/pulumi/pulumi-terraform-provider/sdks/go/tencentcloud/tencentcloud"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		fooUserInfo, err := tencentcloud.GetUserInfo(ctx, &tencentcloud.GetUserInfoArgs{}, nil)
		if err != nil {
			return err
		}
		fooEbEventBus, err := tencentcloud.NewEbEventBus(ctx, "fooEbEventBus", &tencentcloud.EbEventBusArgs{
			EventBusName: pulumi.String("tf-event_bus"),
			Description:  pulumi.String("event bus desc"),
			EnableStore:  pulumi.Bool(false),
			SaveDays:     pulumi.Float64(1),
			Tags: pulumi.StringMap{
				"createdBy": pulumi.String("terraform"),
			},
		})
		if err != nil {
			return err
		}
		service, err := tencentcloud.NewApiGatewayService(ctx, "service", &tencentcloud.ApiGatewayServiceArgs{
			ServiceName: pulumi.String("tf-eb-service"),
			Protocol:    pulumi.String("http&https"),
			ServiceDesc: pulumi.String("your nice service"),
			NetTypes: pulumi.StringArray{
				pulumi.String("INNER"),
				pulumi.String("OUTER"),
			},
			IpVersion: pulumi.String("IPv4"),
		})
		if err != nil {
			return err
		}
		uin := fooUserInfo.OwnerUin
		serviceId := service.ApiGatewayServiceId
		_, err = tencentcloud.NewEbEventConnector(ctx, "eventConnector", &tencentcloud.EbEventConnectorArgs{
			EventBusId:     fooEbEventBus.EbEventBusId,
			ConnectionName: pulumi.String("tf-event-connector"),
			Description:    pulumi.String("event connector desc1"),
			Enable:         pulumi.Bool(false),
			Type:           pulumi.String("apigw"),
			ConnectionDescription: &tencentcloud.EbEventConnectorConnectionDescriptionArgs{
				ResourceDescription: serviceId.ApplyT(func(serviceId string) (string, error) {
					return fmt.Sprintf("qcs::apigw:ap-guangzhou:uin/%v:serviceid/%v", uin, serviceId), nil
				}).(pulumi.StringOutput),
				ApiGwParams: &tencentcloud.EbEventConnectorConnectionDescriptionApiGwParamsArgs{
					Protocol: pulumi.String("HTTP"),
					Method:   pulumi.String("GET"),
				},
			},
		})
		if err != nil {
			return err
		}
		return nil
	})
}
Copy
using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Tencentcloud = Pulumi.Tencentcloud;

return await Deployment.RunAsync(() => 
{
    var fooUserInfo = Tencentcloud.GetUserInfo.Invoke();

    var fooEbEventBus = new Tencentcloud.EbEventBus("fooEbEventBus", new()
    {
        EventBusName = "tf-event_bus",
        Description = "event bus desc",
        EnableStore = false,
        SaveDays = 1,
        Tags = 
        {
            { "createdBy", "terraform" },
        },
    });

    var service = new Tencentcloud.ApiGatewayService("service", new()
    {
        ServiceName = "tf-eb-service",
        Protocol = "http&https",
        ServiceDesc = "your nice service",
        NetTypes = new[]
        {
            "INNER",
            "OUTER",
        },
        IpVersion = "IPv4",
    });

    var uin = fooUserInfo.Apply(getUserInfoResult => getUserInfoResult.OwnerUin);

    var serviceId = service.ApiGatewayServiceId;

    var eventConnector = new Tencentcloud.EbEventConnector("eventConnector", new()
    {
        EventBusId = fooEbEventBus.EbEventBusId,
        ConnectionName = "tf-event-connector",
        Description = "event connector desc1",
        Enable = false,
        Type = "apigw",
        ConnectionDescription = new Tencentcloud.Inputs.EbEventConnectorConnectionDescriptionArgs
        {
            ResourceDescription = Output.Tuple(uin, serviceId).Apply(values =>
            {
                var uin = values.Item1;
                var serviceId = values.Item2;
                return $"qcs::apigw:ap-guangzhou:uin/{uin}:serviceid/{serviceId}";
            }),
            ApiGwParams = new Tencentcloud.Inputs.EbEventConnectorConnectionDescriptionApiGwParamsArgs
            {
                Protocol = "HTTP",
                Method = "GET",
            },
        },
    });

});
Copy
package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.tencentcloud.TencentcloudFunctions;
import com.pulumi.tencentcloud.inputs.GetUserInfoArgs;
import com.pulumi.tencentcloud.EbEventBus;
import com.pulumi.tencentcloud.EbEventBusArgs;
import com.pulumi.tencentcloud.ApiGatewayService;
import com.pulumi.tencentcloud.ApiGatewayServiceArgs;
import com.pulumi.tencentcloud.EbEventConnector;
import com.pulumi.tencentcloud.EbEventConnectorArgs;
import com.pulumi.tencentcloud.inputs.EbEventConnectorConnectionDescriptionArgs;
import com.pulumi.tencentcloud.inputs.EbEventConnectorConnectionDescriptionApiGwParamsArgs;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;

public class App {
    public static void main(String[] args) {
        Pulumi.run(App::stack);
    }

    public static void stack(Context ctx) {
        final var fooUserInfo = TencentcloudFunctions.getUserInfo();

        var fooEbEventBus = new EbEventBus("fooEbEventBus", EbEventBusArgs.builder()
            .eventBusName("tf-event_bus")
            .description("event bus desc")
            .enableStore(false)
            .saveDays(1)
            .tags(Map.of("createdBy", "terraform"))
            .build());

        var service = new ApiGatewayService("service", ApiGatewayServiceArgs.builder()
            .serviceName("tf-eb-service")
            .protocol("http&https")
            .serviceDesc("your nice service")
            .netTypes(            
                "INNER",
                "OUTER")
            .ipVersion("IPv4")
            .build());

        final var uin = fooUserInfo.applyValue(getUserInfoResult -> getUserInfoResult.ownerUin());

        final var serviceId = service.apiGatewayServiceId();

        var eventConnector = new EbEventConnector("eventConnector", EbEventConnectorArgs.builder()
            .eventBusId(fooEbEventBus.ebEventBusId())
            .connectionName("tf-event-connector")
            .description("event connector desc1")
            .enable(false)
            .type("apigw")
            .connectionDescription(EbEventConnectorConnectionDescriptionArgs.builder()
                .resourceDescription(serviceId.applyValue(serviceId -> String.format("qcs::apigw:ap-guangzhou:uin/%s:serviceid/%s", uin,serviceId)))
                .apiGwParams(EbEventConnectorConnectionDescriptionApiGwParamsArgs.builder()
                    .protocol("HTTP")
                    .method("GET")
                    .build())
                .build())
            .build());

    }
}
Copy
resources:
  fooEbEventBus:
    type: tencentcloud:EbEventBus
    properties:
      eventBusName: tf-event_bus
      description: event bus desc
      enableStore: false
      saveDays: 1
      tags:
        createdBy: terraform
  service:
    type: tencentcloud:ApiGatewayService
    properties:
      serviceName: tf-eb-service
      protocol: http&https
      serviceDesc: your nice service
      netTypes:
        - INNER
        - OUTER
      ipVersion: IPv4
  eventConnector:
    type: tencentcloud:EbEventConnector
    properties:
      eventBusId: ${fooEbEventBus.ebEventBusId}
      connectionName: tf-event-connector
      description: event connector desc1
      enable: false
      type: apigw
      connectionDescription:
        resourceDescription: qcs::apigw:ap-guangzhou:uin/${uin}:serviceid/${serviceId}
        apiGwParams:
          protocol: HTTP
          method: GET
variables:
  fooUserInfo:
    fn::invoke:
      function: tencentcloud:getUserInfo
      arguments: {}
  uin: ${fooUserInfo.ownerUin}
  serviceId: ${service.apiGatewayServiceId}
Copy

Create EbEventConnector Resource

Resources are created with functions called constructors. To learn more about declaring and configuring resources, see Resources.

Constructor syntax

new EbEventConnector(name: string, args: EbEventConnectorArgs, opts?: CustomResourceOptions);
@overload
def EbEventConnector(resource_name: str,
                     args: EbEventConnectorArgs,
                     opts: Optional[ResourceOptions] = None)

@overload
def EbEventConnector(resource_name: str,
                     opts: Optional[ResourceOptions] = None,
                     connection_description: Optional[EbEventConnectorConnectionDescriptionArgs] = None,
                     connection_name: Optional[str] = None,
                     event_bus_id: Optional[str] = None,
                     description: Optional[str] = None,
                     eb_event_connector_id: Optional[str] = None,
                     enable: Optional[bool] = None,
                     type: Optional[str] = None)
func NewEbEventConnector(ctx *Context, name string, args EbEventConnectorArgs, opts ...ResourceOption) (*EbEventConnector, error)
public EbEventConnector(string name, EbEventConnectorArgs args, CustomResourceOptions? opts = null)
public EbEventConnector(String name, EbEventConnectorArgs args)
public EbEventConnector(String name, EbEventConnectorArgs args, CustomResourceOptions options)
type: tencentcloud:EbEventConnector
properties: # The arguments to resource properties.
options: # Bag of options to control resource's behavior.

Parameters

name This property is required. string
The unique name of the resource.
args This property is required. EbEventConnectorArgs
The arguments to resource properties.
opts CustomResourceOptions
Bag of options to control resource's behavior.
resource_name This property is required. str
The unique name of the resource.
args This property is required. EbEventConnectorArgs
The arguments to resource properties.
opts ResourceOptions
Bag of options to control resource's behavior.
ctx Context
Context object for the current deployment.
name This property is required. string
The unique name of the resource.
args This property is required. EbEventConnectorArgs
The arguments to resource properties.
opts ResourceOption
Bag of options to control resource's behavior.
name This property is required. string
The unique name of the resource.
args This property is required. EbEventConnectorArgs
The arguments to resource properties.
opts CustomResourceOptions
Bag of options to control resource's behavior.
name This property is required. String
The unique name of the resource.
args This property is required. EbEventConnectorArgs
The arguments to resource properties.
options CustomResourceOptions
Bag of options to control resource's behavior.

EbEventConnector Resource Properties

To learn more about resource properties and how to use them, see Inputs and Outputs in the Architecture and Concepts docs.

Inputs

In Python, inputs that are objects can be passed either as argument classes or as dictionary literals.

The EbEventConnector resource accepts the following input properties:

ConnectionDescription This property is required. EbEventConnectorConnectionDescription
Connector description.
ConnectionName This property is required. string
connector name.
EventBusId This property is required. string
event bus Id.
Description string
description.
EbEventConnectorId string
ID of the resource.
Enable bool
switch.
Type string
type.
ConnectionDescription This property is required. EbEventConnectorConnectionDescriptionArgs
Connector description.
ConnectionName This property is required. string
connector name.
EventBusId This property is required. string
event bus Id.
Description string
description.
EbEventConnectorId string
ID of the resource.
Enable bool
switch.
Type string
type.
connectionDescription This property is required. EbEventConnectorConnectionDescription
Connector description.
connectionName This property is required. String
connector name.
eventBusId This property is required. String
event bus Id.
description String
description.
ebEventConnectorId String
ID of the resource.
enable Boolean
switch.
type String
type.
connectionDescription This property is required. EbEventConnectorConnectionDescription
Connector description.
connectionName This property is required. string
connector name.
eventBusId This property is required. string
event bus Id.
description string
description.
ebEventConnectorId string
ID of the resource.
enable boolean
switch.
type string
type.
connection_description This property is required. EbEventConnectorConnectionDescriptionArgs
Connector description.
connection_name This property is required. str
connector name.
event_bus_id This property is required. str
event bus Id.
description str
description.
eb_event_connector_id str
ID of the resource.
enable bool
switch.
type str
type.
connectionDescription This property is required. Property Map
Connector description.
connectionName This property is required. String
connector name.
eventBusId This property is required. String
event bus Id.
description String
description.
ebEventConnectorId String
ID of the resource.
enable Boolean
switch.
type String
type.

Outputs

All input properties are implicitly available as output properties. Additionally, the EbEventConnector resource produces the following output properties:

Id string
The provider-assigned unique ID for this managed resource.
Id string
The provider-assigned unique ID for this managed resource.
id String
The provider-assigned unique ID for this managed resource.
id string
The provider-assigned unique ID for this managed resource.
id str
The provider-assigned unique ID for this managed resource.
id String
The provider-assigned unique ID for this managed resource.

Look up Existing EbEventConnector Resource

Get an existing EbEventConnector resource’s state with the given name, ID, and optional extra properties used to qualify the lookup.

public static get(name: string, id: Input<ID>, state?: EbEventConnectorState, opts?: CustomResourceOptions): EbEventConnector
@staticmethod
def get(resource_name: str,
        id: str,
        opts: Optional[ResourceOptions] = None,
        connection_description: Optional[EbEventConnectorConnectionDescriptionArgs] = None,
        connection_name: Optional[str] = None,
        description: Optional[str] = None,
        eb_event_connector_id: Optional[str] = None,
        enable: Optional[bool] = None,
        event_bus_id: Optional[str] = None,
        type: Optional[str] = None) -> EbEventConnector
func GetEbEventConnector(ctx *Context, name string, id IDInput, state *EbEventConnectorState, opts ...ResourceOption) (*EbEventConnector, error)
public static EbEventConnector Get(string name, Input<string> id, EbEventConnectorState? state, CustomResourceOptions? opts = null)
public static EbEventConnector get(String name, Output<String> id, EbEventConnectorState state, CustomResourceOptions options)
resources:  _:    type: tencentcloud:EbEventConnector    get:      id: ${id}
name This property is required.
The unique name of the resulting resource.
id This property is required.
The unique provider ID of the resource to lookup.
state
Any extra arguments used during the lookup.
opts
A bag of options that control this resource's behavior.
resource_name This property is required.
The unique name of the resulting resource.
id This property is required.
The unique provider ID of the resource to lookup.
name This property is required.
The unique name of the resulting resource.
id This property is required.
The unique provider ID of the resource to lookup.
state
Any extra arguments used during the lookup.
opts
A bag of options that control this resource's behavior.
name This property is required.
The unique name of the resulting resource.
id This property is required.
The unique provider ID of the resource to lookup.
state
Any extra arguments used during the lookup.
opts
A bag of options that control this resource's behavior.
name This property is required.
The unique name of the resulting resource.
id This property is required.
The unique provider ID of the resource to lookup.
state
Any extra arguments used during the lookup.
opts
A bag of options that control this resource's behavior.
The following state arguments are supported:
ConnectionDescription EbEventConnectorConnectionDescription
Connector description.
ConnectionName string
connector name.
Description string
description.
EbEventConnectorId string
ID of the resource.
Enable bool
switch.
EventBusId string
event bus Id.
Type string
type.
ConnectionDescription EbEventConnectorConnectionDescriptionArgs
Connector description.
ConnectionName string
connector name.
Description string
description.
EbEventConnectorId string
ID of the resource.
Enable bool
switch.
EventBusId string
event bus Id.
Type string
type.
connectionDescription EbEventConnectorConnectionDescription
Connector description.
connectionName String
connector name.
description String
description.
ebEventConnectorId String
ID of the resource.
enable Boolean
switch.
eventBusId String
event bus Id.
type String
type.
connectionDescription EbEventConnectorConnectionDescription
Connector description.
connectionName string
connector name.
description string
description.
ebEventConnectorId string
ID of the resource.
enable boolean
switch.
eventBusId string
event bus Id.
type string
type.
connection_description EbEventConnectorConnectionDescriptionArgs
Connector description.
connection_name str
connector name.
description str
description.
eb_event_connector_id str
ID of the resource.
enable bool
switch.
event_bus_id str
event bus Id.
type str
type.
connectionDescription Property Map
Connector description.
connectionName String
connector name.
description String
description.
ebEventConnectorId String
ID of the resource.
enable Boolean
switch.
eventBusId String
event bus Id.
type String
type.

Supporting Types

EbEventConnectorConnectionDescription
, EbEventConnectorConnectionDescriptionArgs

ResourceDescription This property is required. string
Resource qcs six-segment style, more reference resource six-segment style.
ApiGwParams EbEventConnectorConnectionDescriptionApiGwParams
apigw parameter,Note: This field may return null, indicating that no valid value can be obtained.
CkafkaParams EbEventConnectorConnectionDescriptionCkafkaParams
ckafka parameter, note: this field may return null, indicating that no valid value can be obtained.
ResourceDescription This property is required. string
Resource qcs six-segment style, more reference resource six-segment style.
ApiGwParams EbEventConnectorConnectionDescriptionApiGwParams
apigw parameter,Note: This field may return null, indicating that no valid value can be obtained.
CkafkaParams EbEventConnectorConnectionDescriptionCkafkaParams
ckafka parameter, note: this field may return null, indicating that no valid value can be obtained.
resourceDescription This property is required. String
Resource qcs six-segment style, more reference resource six-segment style.
apiGwParams EbEventConnectorConnectionDescriptionApiGwParams
apigw parameter,Note: This field may return null, indicating that no valid value can be obtained.
ckafkaParams EbEventConnectorConnectionDescriptionCkafkaParams
ckafka parameter, note: this field may return null, indicating that no valid value can be obtained.
resourceDescription This property is required. string
Resource qcs six-segment style, more reference resource six-segment style.
apiGwParams EbEventConnectorConnectionDescriptionApiGwParams
apigw parameter,Note: This field may return null, indicating that no valid value can be obtained.
ckafkaParams EbEventConnectorConnectionDescriptionCkafkaParams
ckafka parameter, note: this field may return null, indicating that no valid value can be obtained.
resource_description This property is required. str
Resource qcs six-segment style, more reference resource six-segment style.
api_gw_params EbEventConnectorConnectionDescriptionApiGwParams
apigw parameter,Note: This field may return null, indicating that no valid value can be obtained.
ckafka_params EbEventConnectorConnectionDescriptionCkafkaParams
ckafka parameter, note: this field may return null, indicating that no valid value can be obtained.
resourceDescription This property is required. String
Resource qcs six-segment style, more reference resource six-segment style.
apiGwParams Property Map
apigw parameter,Note: This field may return null, indicating that no valid value can be obtained.
ckafkaParams Property Map
ckafka parameter, note: this field may return null, indicating that no valid value can be obtained.

EbEventConnectorConnectionDescriptionApiGwParams
, EbEventConnectorConnectionDescriptionApiGwParamsArgs

Method This property is required. string
POST.
Protocol This property is required. string
HTTPS.
Method This property is required. string
POST.
Protocol This property is required. string
HTTPS.
method This property is required. String
POST.
protocol This property is required. String
HTTPS.
method This property is required. string
POST.
protocol This property is required. string
HTTPS.
method This property is required. str
POST.
protocol This property is required. str
HTTPS.
method This property is required. String
POST.
protocol This property is required. String
HTTPS.

EbEventConnectorConnectionDescriptionCkafkaParams
, EbEventConnectorConnectionDescriptionCkafkaParamsArgs

Offset This property is required. string
kafka offset.
TopicName This property is required. string
ckafka topic.
Offset This property is required. string
kafka offset.
TopicName This property is required. string
ckafka topic.
offset This property is required. String
kafka offset.
topicName This property is required. String
ckafka topic.
offset This property is required. string
kafka offset.
topicName This property is required. string
ckafka topic.
offset This property is required. str
kafka offset.
topic_name This property is required. str
ckafka topic.
offset This property is required. String
kafka offset.
topicName This property is required. String
ckafka topic.

Import

eb event_connector can be imported using the id, e.g.

$ pulumi import tencentcloud:index/ebEventConnector:EbEventConnector event_connector eventBusId#connectionId
Copy

To learn more about importing existing cloud resources, see Importing resources.

Package Details

Repository
tencentcloud tencentcloudstack/terraform-provider-tencentcloud
License
Notes
This Pulumi package is based on the tencentcloud Terraform Provider.