Sign in Dashboard Get started
  1. Registry
  2. Packages
  3. Alibaba Cloud Provider
  4. API Docs
  5. eventbridge
  6. EventStreaming
Viewing docs for Alibaba Cloud v3.108.0
published on Thursday, Sep 17, 2026 by Pulumi
Schema (JSON)
pulumi/pulumi-alicloud

alicloud.eventbridge.EventStreaming

alicloud logo alicloud logo
Viewing docs for Alibaba Cloud v3.108.0
published on Thursday, Sep 17, 2026 by Pulumi
Schema (JSON)
pulumi/pulumi-alicloud

    Provides a Event Bridge Event Streaming resource.

    An event streaming allows you to stream events from an event source to an event target, with optional event filtering and transformation.

    For information about Event Bridge Event Streaming and how to use it, see What is Event Streaming.

    NOTE: Available since v1.293.0.

    Example Usage

    Basic Usage

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

const config = new pulumi.Config();
const name = config.get("name") || "terraform-example";
const source = new alicloud.message.ServiceQueue("source", {queueName: `${name}-source`});
const sink = new alicloud.message.ServiceQueue("sink", {queueName: `${name}-sink`});
const _default = new alicloud.eventbridge.EventStreaming("default", {
    eventStreamingName: name,
    description: "terraform-example-event-streaming",
    filterPattern: "{}",
    source: pulumi.jsonStringify({
        SourceMNSParameters: {
            RegionId: "cn-hangzhou",
            QueueName: source.queueName,
            IsBase64Decode: true,
        },
    }),
    sink: pulumi.jsonStringify({
        SinkMNSParameters: {
            QueueName: {
                Value: sink.queueName,
                Form: "CONSTANT",
            },
            Body: {
                Value: "$.data",
                Form: "JSONPATH",
            },
            IsBase64Encode: {
                Value: "true",
                Form: "CONSTANT",
            },
        },
    }),
});

    import pulumi
import json
import pulumi_alicloud as alicloud

config = pulumi.Config()
name = config.get("name")
if name is None:
    name = "terraform-example"
source = alicloud.message.ServiceQueue("source", queue_name=f"{name}-source")
sink = alicloud.message.ServiceQueue("sink", queue_name=f"{name}-sink")
default = alicloud.eventbridge.EventStreaming("default",
    event_streaming_name=name,
    description="terraform-example-event-streaming",
    filter_pattern="{}",
    source=pulumi.Output.json_dumps({
        "SourceMNSParameters": {
            "RegionId": "cn-hangzhou",
            "QueueName": source.queue_name,
            "IsBase64Decode": True,
        },
    }),
    sink=pulumi.Output.json_dumps({
        "SinkMNSParameters": {
            "QueueName": {
                "Value": sink.queue_name,
                "Form": "CONSTANT",
            },
            "Body": {
                "Value": "$.data",
                "Form": "JSONPATH",
            },
            "IsBase64Encode": {
                "Value": "true",
                "Form": "CONSTANT",
            },
        },
    }))

    package main

import (
	"encoding/json"

	"github.com/pulumi/pulumi-alicloud/sdk/v3/go/alicloud/eventbridge"
	"github.com/pulumi/pulumi-alicloud/sdk/v3/go/alicloud/message"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi/config"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		cfg := config.New(ctx, "")
		name := "terraform-example"
		if param := cfg.Get("name"); param != "" {
			name = param
		}
		source, err := message.NewServiceQueue(ctx, "source", &message.ServiceQueueArgs{
			QueueName: pulumi.Sprintf("%v-source", name),
		})
		if err != nil {
			return err
		}
		sink, err := message.NewServiceQueue(ctx, "sink", &message.ServiceQueueArgs{
			QueueName: pulumi.Sprintf("%v-sink", name),
		})
		if err != nil {
			return err
		}
		_, err = eventbridge.NewEventStreaming(ctx, "default", &eventbridge.EventStreamingArgs{
			EventStreamingName: pulumi.String(name),
			Description:        pulumi.String("terraform-example-event-streaming"),
			FilterPattern:      pulumi.String("{}"),
			Source: source.QueueName.ApplyT(func(queueName string) (pulumi.String, error) {
				var _zero pulumi.String
				tmpJSON0, err := json.Marshal(map[string]map[string]interface{}{
					"SourceMNSParameters": map[string]interface{}{
						"RegionId":       "cn-hangzhou",
						"QueueName":      queueName,
						"IsBase64Decode": true,
					},
				})
				if err != nil {
					return _zero, err
				}
				json0 := string(tmpJSON0)
				return pulumi.String(json0), nil
			}).(pulumi.StringOutput),
			Sink: sink.QueueName.ApplyT(func(queueName string) (pulumi.String, error) {
				var _zero pulumi.String
				tmpJSON1, err := json.Marshal(map[string]map[string]map[string]string{
					"SinkMNSParameters": map[string]map[string]string{
						"QueueName": map[string]string{
							"Value": queueName,
							"Form":  "CONSTANT",
						},
						"Body": map[string]string{
							"Value": "$.data",
							"Form":  "JSONPATH",
						},
						"IsBase64Encode": map[string]string{
							"Value": "true",
							"Form":  "CONSTANT",
						},
					},
				})
				if err != nil {
					return _zero, err
				}
				json1 := string(tmpJSON1)
				return pulumi.String(json1), nil
			}).(pulumi.StringOutput),
		})
		if err != nil {
			return err
		}
		return nil
	})
}

    using System.Collections.Generic;
using System.Linq;
using System.Text.Json;
using Pulumi;
using AliCloud = Pulumi.AliCloud;

return await Deployment.RunAsync(() => 
{
    var config = new Config();
    var name = config.Get("name") ?? "terraform-example";
    var source = new AliCloud.Message.ServiceQueue("source", new()
    {
        QueueName = $"{name}-source",
    });

    var sink = new AliCloud.Message.ServiceQueue("sink", new()
    {
        QueueName = $"{name}-sink",
    });

    var @default = new AliCloud.EventBridge.EventStreaming("default", new()
    {
        EventStreamingName = name,
        Description = "terraform-example-event-streaming",
        FilterPattern = "{}",
        Source = Output.JsonSerialize(Output.Create(new Dictionary<string, object?>
        {
            ["SourceMNSParameters"] = new Dictionary<string, object?>
            {
                ["RegionId"] = "cn-hangzhou",
                ["QueueName"] = source.QueueName,
                ["IsBase64Decode"] = true,
            },
        })),
        Sink = Output.JsonSerialize(Output.Create(new Dictionary<string, object?>
        {
            ["SinkMNSParameters"] = new Dictionary<string, object?>
            {
                ["QueueName"] = new Dictionary<string, object?>
                {
                    ["Value"] = sink.QueueName,
                    ["Form"] = "CONSTANT",
                },
                ["Body"] = new Dictionary<string, object?>
                {
                    ["Value"] = "$.data",
                    ["Form"] = "JSONPATH",
                },
                ["IsBase64Encode"] = new Dictionary<string, object?>
                {
                    ["Value"] = "true",
                    ["Form"] = "CONSTANT",
                },
            },
        })),
    });

});

    package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.alicloud.message.ServiceQueue;
import com.pulumi.alicloud.message.ServiceQueueArgs;
import com.pulumi.alicloud.eventbridge.EventStreaming;
import com.pulumi.alicloud.eventbridge.EventStreamingArgs;
import static com.pulumi.codegen.internal.Serialization.*;
import java.util.ArrayList;
import java.util.Arrays;
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 config = ctx.config();
        final var name = config.get("name").orElse("terraform-example");
        var source = new ServiceQueue("source", ServiceQueueArgs.builder()
            .queueName(String.format("%s-source", name))
            .build());

        var sink = new ServiceQueue("sink", ServiceQueueArgs.builder()
            .queueName(String.format("%s-sink", name))
            .build());

        var default_ = new EventStreaming("default", EventStreamingArgs.builder()
            .eventStreamingName(name)
            .description("terraform-example-event-streaming")
            .filterPattern("{}")
            .source(source.queueName().applyValue(_queueName -> serializeJson(
                jsonObject(
                    jsonProperty("SourceMNSParameters", jsonObject(
                        jsonProperty("RegionId", "cn-hangzhou"),
                        jsonProperty("QueueName", _queueName),
                        jsonProperty("IsBase64Decode", true)
                    ))
                ))))
            .sink(sink.queueName().applyValue(_queueName -> serializeJson(
                jsonObject(
                    jsonProperty("SinkMNSParameters", jsonObject(
                        jsonProperty("QueueName", jsonObject(
                            jsonProperty("Value", _queueName),
                            jsonProperty("Form", "CONSTANT")
                        )),
                        jsonProperty("Body", jsonObject(
                            jsonProperty("Value", "$.data"),
                            jsonProperty("Form", "JSONPATH")
                        )),
                        jsonProperty("IsBase64Encode", jsonObject(
                            jsonProperty("Value", "true"),
                            jsonProperty("Form", "CONSTANT")
                        ))
                    ))
                ))))
            .build());

    }
}

    configuration:
  name:
    type: string
    default: terraform-example
resources:
  source:
    type: alicloud:message:ServiceQueue
    properties:
      queueName: ${name}-source
  sink:
    type: alicloud:message:ServiceQueue
    properties:
      queueName: ${name}-sink
  default:
    type: alicloud:eventbridge:EventStreaming
    properties:
      eventStreamingName: ${name}
      description: terraform-example-event-streaming
      filterPattern: '{}'
      source:
        fn::toJSON:
          SourceMNSParameters:
            RegionId: cn-hangzhou
            QueueName: ${source.queueName}
            IsBase64Decode: true
      sink:
        fn::toJSON:
          SinkMNSParameters:
            QueueName:
              Value: ${sink.queueName}
              Form: CONSTANT
            Body:
              Value: $.data
              Form: JSONPATH
            IsBase64Encode:
              Value: 'true'
              Form: CONSTANT

    pulumi {
  required_providers {
    alicloud = {
      source = "pulumi/alicloud"
    }
  }
}

resource "alicloud_message_servicequeue" "source" {
  queue_name ="${var.name}-source"
}
resource "alicloud_message_servicequeue" "sink" {
  queue_name ="${var.name}-sink"
}
resource "alicloud_eventbridge_eventstreaming" "default" {
  event_streaming_name = var.name
  description          = "terraform-example-event-streaming"
  filter_pattern       = "{}"
  source = jsonencode({
    "SourceMNSParameters" = {
      "RegionId"       = "cn-hangzhou"
      "QueueName"      = alicloud_message_servicequeue.source.queue_name
      "IsBase64Decode" = true
    }
  })
  sink = jsonencode({
    "SinkMNSParameters" = {
      "QueueName" = {
        "Value" = alicloud_message_servicequeue.sink.queue_name
        "Form"  = "CONSTANT"
      }
      "Body" = {
        "Value" = "$.data"
        "Form"  = "JSONPATH"
      }
      "IsBase64Encode" = {
        "Value" = "true"
        "Form"  = "CONSTANT"
      }
    }
  })
}
variable "name" {
  type    = string
  default = "terraform-example"
}

    Create EventStreaming Resource

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

    Constructor syntax

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

@overload
def EventStreaming(resource_name: str,
                   opts: Optional[ResourceOptions] = None,
                   event_streaming_name: Optional[str] = None,
                   filter_pattern: Optional[str] = None,
                   sink: Optional[str] = None,
                   source: Optional[str] = None,
                   description: Optional[str] = None,
                   run_options: Optional[str] = None,
                   status: Optional[str] = None,
                   tags: Optional[Mapping[str, str]] = None,
                   transforms: Optional[str] = None)
    func NewEventStreaming(ctx *Context, name string, args EventStreamingArgs, opts ...ResourceOption) (*EventStreaming, error)
    public EventStreaming(string name, EventStreamingArgs args, CustomResourceOptions? opts = null)
    public EventStreaming(String name, EventStreamingArgs args)
public EventStreaming(String name, EventStreamingArgs args, CustomResourceOptions options)

    type: alicloud:eventbridge:EventStreaming
properties: # The arguments to resource properties.
options: # Bag of options to control resource's behavior.


    resource "alicloud_eventbridge_event_streaming" "name" {
    # resource properties
}

    Parameters

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

    Constructor example

    The following reference example uses placeholder values for all input properties.

    var eventStreamingResource = new AliCloud.EventBridge.EventStreaming("eventStreamingResource", new()
{
    EventStreamingName = "string",
    FilterPattern = "string",
    Sink = "string",
    Source = "string",
    Description = "string",
    RunOptions = "string",
    Status = "string",
    Tags = 
    {
        { "string", "string" },
    },
    Transforms = "string",
});

    example, err := eventbridge.NewEventStreaming(ctx, "eventStreamingResource", &eventbridge.EventStreamingArgs{
	EventStreamingName: pulumi.String("string"),
	FilterPattern:      pulumi.String("string"),
	Sink:               pulumi.String("string"),
	Source:             pulumi.String("string"),
	Description:        pulumi.String("string"),
	RunOptions:         pulumi.String("string"),
	Status:             pulumi.String("string"),
	Tags: pulumi.StringMap{
		"string": pulumi.String("string"),
	},
	Transforms: pulumi.String("string"),
})

    resource "alicloud_eventbridge_event_streaming" "eventStreamingResource" {
  lifecycle {
    create_before_destroy = true
  }
  event_streaming_name = "string"
  filter_pattern       = "string"
  sink                 = "string"
  source               = "string"
  description          = "string"
  run_options          = "string"
  status               = "string"
  tags = {
    "string" = "string"
  }
  transforms = "string"
}

    var eventStreamingResource = new EventStreaming("eventStreamingResource", EventStreamingArgs.builder()
    .eventStreamingName("string")
    .filterPattern("string")
    .sink("string")
    .source("string")
    .description("string")
    .runOptions("string")
    .status("string")
    .tags(Map.of("string", "string"))
    .transforms("string")
    .build());

    event_streaming_resource = alicloud.eventbridge.EventStreaming("eventStreamingResource",
    event_streaming_name="string",
    filter_pattern="string",
    sink="string",
    source="string",
    description="string",
    run_options="string",
    status="string",
    tags={
        "string": "string",
    },
    transforms="string")

    const eventStreamingResource = new alicloud.eventbridge.EventStreaming("eventStreamingResource", {
    eventStreamingName: "string",
    filterPattern: "string",
    sink: "string",
    source: "string",
    description: "string",
    runOptions: "string",
    status: "string",
    tags: {
        string: "string",
    },
    transforms: "string",
});

    type: alicloud:eventbridge:EventStreaming
properties:
    description: string
    eventStreamingName: string
    filterPattern: string
    runOptions: string
    sink: string
    source: string
    status: string
    tags:
        string: string
    transforms: string

    EventStreaming 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 EventStreaming resource accepts the following input properties:

    EventStreamingName string
    The name of the event streaming.
    FilterPattern string
    The rule that is used to filter events. If you leave this parameter empty, all events are matched. The value is a JSON string, for example {}.
    Sink string
    The event target. You must and can specify only one event target. The value is a JSON string, for example {"SinkMNSParameters":{"QueueName":{"Value":"example","Form":"CONSTANT"}}}.
    Source string
    The event provider, which is also known as the event source. You must and can specify only one event source. The value is a JSON string, for example {"SourceMNSParameters":{"QueueName":"example","RegionId":"cn-hangzhou","IsBase64Decode":true}}.
    Description string
    The description of the event streaming.
    RunOptions string
    The parameters that are configured for the runtime environment. The value is a JSON string, for example {"ErrorsTolerance":"ALL","MaximumTasks":1}.
    Status string
    The expected status of the event streaming. Valid values: RUNNING and PAUSED. If you set this parameter to RUNNING, the event streaming is started. If you set this parameter to PAUSED, the event streaming is paused. If you do not set this parameter, the event streaming stays in the READY status after it is created.
    Tags Dictionary<string, string>
    A mapping of tags to assign to the resource.
    Transforms string
    The rules that are used to transform events. The value is a JSON array string, for example [{"Arn":"acs:fc:cn-hangzhou:ACCOUNT_ID:functions/example"}].
    EventStreamingName string
    The name of the event streaming.
    FilterPattern string
    The rule that is used to filter events. If you leave this parameter empty, all events are matched. The value is a JSON string, for example {}.
    Sink string
    The event target. You must and can specify only one event target. The value is a JSON string, for example {"SinkMNSParameters":{"QueueName":{"Value":"example","Form":"CONSTANT"}}}.
    Source string
    The event provider, which is also known as the event source. You must and can specify only one event source. The value is a JSON string, for example {"SourceMNSParameters":{"QueueName":"example","RegionId":"cn-hangzhou","IsBase64Decode":true}}.
    Description string
    The description of the event streaming.
    RunOptions string
    The parameters that are configured for the runtime environment. The value is a JSON string, for example {"ErrorsTolerance":"ALL","MaximumTasks":1}.
    Status string
    The expected status of the event streaming. Valid values: RUNNING and PAUSED. If you set this parameter to RUNNING, the event streaming is started. If you set this parameter to PAUSED, the event streaming is paused. If you do not set this parameter, the event streaming stays in the READY status after it is created.
    Tags map[string]string
    A mapping of tags to assign to the resource.
    Transforms string
    The rules that are used to transform events. The value is a JSON array string, for example [{"Arn":"acs:fc:cn-hangzhou:ACCOUNT_ID:functions/example"}].
    event_streaming_name string
    The name of the event streaming.
    filter_pattern string
    The rule that is used to filter events. If you leave this parameter empty, all events are matched. The value is a JSON string, for example {}.
    sink string
    The event target. You must and can specify only one event target. The value is a JSON string, for example {"SinkMNSParameters":{"QueueName":{"Value":"example","Form":"CONSTANT"}}}.
    source string
    The event provider, which is also known as the event source. You must and can specify only one event source. The value is a JSON string, for example {"SourceMNSParameters":{"QueueName":"example","RegionId":"cn-hangzhou","IsBase64Decode":true}}.
    description string
    The description of the event streaming.
    run_options string
    The parameters that are configured for the runtime environment. The value is a JSON string, for example {"ErrorsTolerance":"ALL","MaximumTasks":1}.
    status string
    The expected status of the event streaming. Valid values: RUNNING and PAUSED. If you set this parameter to RUNNING, the event streaming is started. If you set this parameter to PAUSED, the event streaming is paused. If you do not set this parameter, the event streaming stays in the READY status after it is created.
    tags map(string)
    A mapping of tags to assign to the resource.
    transforms string
    The rules that are used to transform events. The value is a JSON array string, for example [{"Arn":"acs:fc:cn-hangzhou:ACCOUNT_ID:functions/example"}].
    eventStreamingName String
    The name of the event streaming.
    filterPattern String
    The rule that is used to filter events. If you leave this parameter empty, all events are matched. The value is a JSON string, for example {}.
    sink String
    The event target. You must and can specify only one event target. The value is a JSON string, for example {"SinkMNSParameters":{"QueueName":{"Value":"example","Form":"CONSTANT"}}}.
    source String
    The event provider, which is also known as the event source. You must and can specify only one event source. The value is a JSON string, for example {"SourceMNSParameters":{"QueueName":"example","RegionId":"cn-hangzhou","IsBase64Decode":true}}.
    description String
    The description of the event streaming.
    runOptions String
    The parameters that are configured for the runtime environment. The value is a JSON string, for example {"ErrorsTolerance":"ALL","MaximumTasks":1}.
    status String
    The expected status of the event streaming. Valid values: RUNNING and PAUSED. If you set this parameter to RUNNING, the event streaming is started. If you set this parameter to PAUSED, the event streaming is paused. If you do not set this parameter, the event streaming stays in the READY status after it is created.
    tags Map<String,String>
    A mapping of tags to assign to the resource.
    transforms String
    The rules that are used to transform events. The value is a JSON array string, for example [{"Arn":"acs:fc:cn-hangzhou:ACCOUNT_ID:functions/example"}].
    eventStreamingName string
    The name of the event streaming.
    filterPattern string
    The rule that is used to filter events. If you leave this parameter empty, all events are matched. The value is a JSON string, for example {}.
    sink string
    The event target. You must and can specify only one event target. The value is a JSON string, for example {"SinkMNSParameters":{"QueueName":{"Value":"example","Form":"CONSTANT"}}}.
    source string
    The event provider, which is also known as the event source. You must and can specify only one event source. The value is a JSON string, for example {"SourceMNSParameters":{"QueueName":"example","RegionId":"cn-hangzhou","IsBase64Decode":true}}.
    description string
    The description of the event streaming.
    runOptions string
    The parameters that are configured for the runtime environment. The value is a JSON string, for example {"ErrorsTolerance":"ALL","MaximumTasks":1}.
    status string
    The expected status of the event streaming. Valid values: RUNNING and PAUSED. If you set this parameter to RUNNING, the event streaming is started. If you set this parameter to PAUSED, the event streaming is paused. If you do not set this parameter, the event streaming stays in the READY status after it is created.
    tags {[key: string]: string}
    A mapping of tags to assign to the resource.
    transforms string
    The rules that are used to transform events. The value is a JSON array string, for example [{"Arn":"acs:fc:cn-hangzhou:ACCOUNT_ID:functions/example"}].
    event_streaming_name str
    The name of the event streaming.
    filter_pattern str
    The rule that is used to filter events. If you leave this parameter empty, all events are matched. The value is a JSON string, for example {}.
    sink str
    The event target. You must and can specify only one event target. The value is a JSON string, for example {"SinkMNSParameters":{"QueueName":{"Value":"example","Form":"CONSTANT"}}}.
    source str
    The event provider, which is also known as the event source. You must and can specify only one event source. The value is a JSON string, for example {"SourceMNSParameters":{"QueueName":"example","RegionId":"cn-hangzhou","IsBase64Decode":true}}.
    description str
    The description of the event streaming.
    run_options str
    The parameters that are configured for the runtime environment. The value is a JSON string, for example {"ErrorsTolerance":"ALL","MaximumTasks":1}.
    status str
    The expected status of the event streaming. Valid values: RUNNING and PAUSED. If you set this parameter to RUNNING, the event streaming is started. If you set this parameter to PAUSED, the event streaming is paused. If you do not set this parameter, the event streaming stays in the READY status after it is created.
    tags Mapping[str, str]
    A mapping of tags to assign to the resource.
    transforms str
    The rules that are used to transform events. The value is a JSON array string, for example [{"Arn":"acs:fc:cn-hangzhou:ACCOUNT_ID:functions/example"}].
    eventStreamingName String
    The name of the event streaming.
    filterPattern String
    The rule that is used to filter events. If you leave this parameter empty, all events are matched. The value is a JSON string, for example {}.
    sink String
    The event target. You must and can specify only one event target. The value is a JSON string, for example {"SinkMNSParameters":{"QueueName":{"Value":"example","Form":"CONSTANT"}}}.
    source String
    The event provider, which is also known as the event source. You must and can specify only one event source. The value is a JSON string, for example {"SourceMNSParameters":{"QueueName":"example","RegionId":"cn-hangzhou","IsBase64Decode":true}}.
    description String
    The description of the event streaming.
    runOptions String
    The parameters that are configured for the runtime environment. The value is a JSON string, for example {"ErrorsTolerance":"ALL","MaximumTasks":1}.
    status String
    The expected status of the event streaming. Valid values: RUNNING and PAUSED. If you set this parameter to RUNNING, the event streaming is started. If you set this parameter to PAUSED, the event streaming is paused. If you do not set this parameter, the event streaming stays in the READY status after it is created.
    tags Map<String>
    A mapping of tags to assign to the resource.
    transforms String
    The rules that are used to transform events. The value is a JSON array string, for example [{"Arn":"acs:fc:cn-hangzhou:ACCOUNT_ID:functions/example"}].

    Outputs

    All input properties are implicitly available as output properties. Additionally, the EventStreaming 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 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 EventStreaming Resource

    Get an existing EventStreaming 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?: EventStreamingState, opts?: CustomResourceOptions): EventStreaming
    @staticmethod
def get(resource_name: str,
        id: str,
        opts: Optional[ResourceOptions] = None,
        description: Optional[str] = None,
        event_streaming_name: Optional[str] = None,
        filter_pattern: Optional[str] = None,
        run_options: Optional[str] = None,
        sink: Optional[str] = None,
        source: Optional[str] = None,
        status: Optional[str] = None,
        tags: Optional[Mapping[str, str]] = None,
        transforms: Optional[str] = None) -> EventStreaming
    func GetEventStreaming(ctx *Context, name string, id IDInput, state *EventStreamingState, opts ...ResourceOption) (*EventStreaming, error)
    public static EventStreaming Get(string name, Input<string> id, EventStreamingState? state, CustomResourceOptions? opts = null)
    public static EventStreaming get(String name, Output<String> id, EventStreamingState state, CustomResourceOptions options)
    resources:  _:    type: alicloud:eventbridge:EventStreaming    get:      id: ${id}
    import {
  to = alicloud_eventbridge_event_streaming.example
  id = "${id}"
}
    name
    The unique name of the resulting resource.
    id
    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
    The unique name of the resulting resource.
    id
    The unique provider ID of the resource to lookup.
    name
    The unique name of the resulting resource.
    id
    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
    The unique name of the resulting resource.
    id
    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
    The unique name of the resulting resource.
    id
    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:
    Description string
    The description of the event streaming.
    EventStreamingName string
    The name of the event streaming.
    FilterPattern string
    The rule that is used to filter events. If you leave this parameter empty, all events are matched. The value is a JSON string, for example {}.
    RunOptions string
    The parameters that are configured for the runtime environment. The value is a JSON string, for example {"ErrorsTolerance":"ALL","MaximumTasks":1}.
    Sink string
    The event target. You must and can specify only one event target. The value is a JSON string, for example {"SinkMNSParameters":{"QueueName":{"Value":"example","Form":"CONSTANT"}}}.
    Source string
    The event provider, which is also known as the event source. You must and can specify only one event source. The value is a JSON string, for example {"SourceMNSParameters":{"QueueName":"example","RegionId":"cn-hangzhou","IsBase64Decode":true}}.
    Status string
    The expected status of the event streaming. Valid values: RUNNING and PAUSED. If you set this parameter to RUNNING, the event streaming is started. If you set this parameter to PAUSED, the event streaming is paused. If you do not set this parameter, the event streaming stays in the READY status after it is created.
    Tags Dictionary<string, string>
    A mapping of tags to assign to the resource.
    Transforms string
    The rules that are used to transform events. The value is a JSON array string, for example [{"Arn":"acs:fc:cn-hangzhou:ACCOUNT_ID:functions/example"}].
    Description string
    The description of the event streaming.
    EventStreamingName string
    The name of the event streaming.
    FilterPattern string
    The rule that is used to filter events. If you leave this parameter empty, all events are matched. The value is a JSON string, for example {}.
    RunOptions string
    The parameters that are configured for the runtime environment. The value is a JSON string, for example {"ErrorsTolerance":"ALL","MaximumTasks":1}.
    Sink string
    The event target. You must and can specify only one event target. The value is a JSON string, for example {"SinkMNSParameters":{"QueueName":{"Value":"example","Form":"CONSTANT"}}}.
    Source string
    The event provider, which is also known as the event source. You must and can specify only one event source. The value is a JSON string, for example {"SourceMNSParameters":{"QueueName":"example","RegionId":"cn-hangzhou","IsBase64Decode":true}}.
    Status string
    The expected status of the event streaming. Valid values: RUNNING and PAUSED. If you set this parameter to RUNNING, the event streaming is started. If you set this parameter to PAUSED, the event streaming is paused. If you do not set this parameter, the event streaming stays in the READY status after it is created.
    Tags map[string]string
    A mapping of tags to assign to the resource.
    Transforms string
    The rules that are used to transform events. The value is a JSON array string, for example [{"Arn":"acs:fc:cn-hangzhou:ACCOUNT_ID:functions/example"}].
    description string
    The description of the event streaming.
    event_streaming_name string
    The name of the event streaming.
    filter_pattern string
    The rule that is used to filter events. If you leave this parameter empty, all events are matched. The value is a JSON string, for example {}.
    run_options string
    The parameters that are configured for the runtime environment. The value is a JSON string, for example {"ErrorsTolerance":"ALL","MaximumTasks":1}.
    sink string
    The event target. You must and can specify only one event target. The value is a JSON string, for example {"SinkMNSParameters":{"QueueName":{"Value":"example","Form":"CONSTANT"}}}.
    source string
    The event provider, which is also known as the event source. You must and can specify only one event source. The value is a JSON string, for example {"SourceMNSParameters":{"QueueName":"example","RegionId":"cn-hangzhou","IsBase64Decode":true}}.
    status string
    The expected status of the event streaming. Valid values: RUNNING and PAUSED. If you set this parameter to RUNNING, the event streaming is started. If you set this parameter to PAUSED, the event streaming is paused. If you do not set this parameter, the event streaming stays in the READY status after it is created.
    tags map(string)
    A mapping of tags to assign to the resource.
    transforms string
    The rules that are used to transform events. The value is a JSON array string, for example [{"Arn":"acs:fc:cn-hangzhou:ACCOUNT_ID:functions/example"}].
    description String
    The description of the event streaming.
    eventStreamingName String
    The name of the event streaming.
    filterPattern String
    The rule that is used to filter events. If you leave this parameter empty, all events are matched. The value is a JSON string, for example {}.
    runOptions String
    The parameters that are configured for the runtime environment. The value is a JSON string, for example {"ErrorsTolerance":"ALL","MaximumTasks":1}.
    sink String
    The event target. You must and can specify only one event target. The value is a JSON string, for example {"SinkMNSParameters":{"QueueName":{"Value":"example","Form":"CONSTANT"}}}.
    source String
    The event provider, which is also known as the event source. You must and can specify only one event source. The value is a JSON string, for example {"SourceMNSParameters":{"QueueName":"example","RegionId":"cn-hangzhou","IsBase64Decode":true}}.
    status String
    The expected status of the event streaming. Valid values: RUNNING and PAUSED. If you set this parameter to RUNNING, the event streaming is started. If you set this parameter to PAUSED, the event streaming is paused. If you do not set this parameter, the event streaming stays in the READY status after it is created.
    tags Map<String,String>
    A mapping of tags to assign to the resource.
    transforms String
    The rules that are used to transform events. The value is a JSON array string, for example [{"Arn":"acs:fc:cn-hangzhou:ACCOUNT_ID:functions/example"}].
    description string
    The description of the event streaming.
    eventStreamingName string
    The name of the event streaming.
    filterPattern string
    The rule that is used to filter events. If you leave this parameter empty, all events are matched. The value is a JSON string, for example {}.
    runOptions string
    The parameters that are configured for the runtime environment. The value is a JSON string, for example {"ErrorsTolerance":"ALL","MaximumTasks":1}.
    sink string
    The event target. You must and can specify only one event target. The value is a JSON string, for example {"SinkMNSParameters":{"QueueName":{"Value":"example","Form":"CONSTANT"}}}.
    source string
    The event provider, which is also known as the event source. You must and can specify only one event source. The value is a JSON string, for example {"SourceMNSParameters":{"QueueName":"example","RegionId":"cn-hangzhou","IsBase64Decode":true}}.
    status string
    The expected status of the event streaming. Valid values: RUNNING and PAUSED. If you set this parameter to RUNNING, the event streaming is started. If you set this parameter to PAUSED, the event streaming is paused. If you do not set this parameter, the event streaming stays in the READY status after it is created.
    tags {[key: string]: string}
    A mapping of tags to assign to the resource.
    transforms string
    The rules that are used to transform events. The value is a JSON array string, for example [{"Arn":"acs:fc:cn-hangzhou:ACCOUNT_ID:functions/example"}].
    description str
    The description of the event streaming.
    event_streaming_name str
    The name of the event streaming.
    filter_pattern str
    The rule that is used to filter events. If you leave this parameter empty, all events are matched. The value is a JSON string, for example {}.
    run_options str
    The parameters that are configured for the runtime environment. The value is a JSON string, for example {"ErrorsTolerance":"ALL","MaximumTasks":1}.
    sink str
    The event target. You must and can specify only one event target. The value is a JSON string, for example {"SinkMNSParameters":{"QueueName":{"Value":"example","Form":"CONSTANT"}}}.
    source str
    The event provider, which is also known as the event source. You must and can specify only one event source. The value is a JSON string, for example {"SourceMNSParameters":{"QueueName":"example","RegionId":"cn-hangzhou","IsBase64Decode":true}}.
    status str
    The expected status of the event streaming. Valid values: RUNNING and PAUSED. If you set this parameter to RUNNING, the event streaming is started. If you set this parameter to PAUSED, the event streaming is paused. If you do not set this parameter, the event streaming stays in the READY status after it is created.
    tags Mapping[str, str]
    A mapping of tags to assign to the resource.
    transforms str
    The rules that are used to transform events. The value is a JSON array string, for example [{"Arn":"acs:fc:cn-hangzhou:ACCOUNT_ID:functions/example"}].
    description String
    The description of the event streaming.
    eventStreamingName String
    The name of the event streaming.
    filterPattern String
    The rule that is used to filter events. If you leave this parameter empty, all events are matched. The value is a JSON string, for example {}.
    runOptions String
    The parameters that are configured for the runtime environment. The value is a JSON string, for example {"ErrorsTolerance":"ALL","MaximumTasks":1}.
    sink String
    The event target. You must and can specify only one event target. The value is a JSON string, for example {"SinkMNSParameters":{"QueueName":{"Value":"example","Form":"CONSTANT"}}}.
    source String
    The event provider, which is also known as the event source. You must and can specify only one event source. The value is a JSON string, for example {"SourceMNSParameters":{"QueueName":"example","RegionId":"cn-hangzhou","IsBase64Decode":true}}.
    status String
    The expected status of the event streaming. Valid values: RUNNING and PAUSED. If you set this parameter to RUNNING, the event streaming is started. If you set this parameter to PAUSED, the event streaming is paused. If you do not set this parameter, the event streaming stays in the READY status after it is created.
    tags Map<String>
    A mapping of tags to assign to the resource.
    transforms String
    The rules that are used to transform events. The value is a JSON array string, for example [{"Arn":"acs:fc:cn-hangzhou:ACCOUNT_ID:functions/example"}].

    Import

    Event Bridge Event Streaming can be imported using the id, e.g.

    $ pulumi import alicloud:eventbridge/eventStreaming:EventStreaming example <event_streaming_name>

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

    Package Details

    Repository
    Alibaba Cloud pulumi/pulumi-alicloud
    License
    Apache-2.0
    Notes
    This Pulumi package is based on the alicloud Terraform Provider.
    alicloud logo alicloud logo
    Viewing docs for Alibaba Cloud v3.108.0
    published on Thursday, Sep 17, 2026 by Pulumi
    Schema (JSON)
    pulumi/pulumi-alicloud

      Try Pulumi Cloud free.
      Your team will thank you.

      Start free trial