Sensors Data Data Subscription API

openapi: 3.2.0
info:
  description: 订阅管理服务
  title: 神策数界 Data Subscription API
  version: ''
servers:
- url: /api/v3/horizon/v1
tags:
- name: Data Subscription
paths:
  /data-subscription/application/add:
    post:
      description: "创建订阅方\n ```\n curl -X POST 'http://{host}:8107/api/v3/horizon/v1/data-subscription/application/add' \\\n -H 'api-key: {api-key}' \\\n -H 'Content-Type: application/json;charset=UTF-8' \\\n -H 'sensorsdata-project: {project_name}' \\\n -d '{\n    \"application\":{\n        \"application_name\": \"{application_name}\",\n        \"application_type\": \"KAFKA_BASED_APP\",\n        \"kafka_based_app_config\": {\n            \"data_format_type\": \"NESTED_JSON\",\n            \"profile_kafka_descriptor\":{\n                \"type\": \"CUSTOMIZED_KAFKA\",\n                \"customized_kafka_descriptor\": {\n                    \"bootstrap_servers\": \"{broker_list}\",\n                    \"topic_name\": \"{profile_data_topic_name}\"\n                }\n            },\n            \"event_kafka_descriptor\":{\n                \"type\": \"CUSTOMIZED_KAFKA\",\n                \"customized_kafka_descriptor\": {\n                    \"bootstrap_servers\": \"{broker_list}\",\n                    \"topic_name\": \"{event_data_topic_name}\"\n                }\n            }\n        }\n    }\n }'\n ```"
      operationId: AddSubscriptionApplication
      parameters:
      - description: 全局唯一的密钥，用于验证和授权访问 API 接口
        in: header
        name: api-key
        required: true
        schema:
          type: string
      - description: 项目名, 指定请求所属项目
        in: header
        name: sensorsdata-project
        required: true
        schema:
          type: string
      requestBody:
        content:
          application/json:
            schema:
              $ref: '#/components/schemas/sensorsdata.horizon.v1.AddSubscriptionApplicationRequest'
        required: false
      responses:
        default:
          content:
            application/json:
              example:
                code: SUCCESS
                data:
                  application:
                    kafka_based_app_config:
                      data_format_type: NESTED_JSON
                      event_kafka_descriptor:
                        customized_kafka_descriptor:
                          bootstrap_servers: broker1:9092,broker2:9092
                          topic_name: shence_data_topic
                        type: CUSTOMIZED_KAFKA
                    application_name: shence
                    application_type: KAFKA_BASED_APP
                request_id: '1'
              schema:
                $ref: '#/components/schemas/sensorsdata.horizon.v1.AddSubscriptionApplicationResponseHttpApiResult'
          description: sensorsdata.horizon.v1.AddSubscriptionApplicationResponse
      summary: 创建订阅方
      x-sd-openapi:
        responseClass: com.sensorsdata.horizon.v1.AddSubscriptionApplicationResponse
        isServerStreaming: false
        requestClass: com.sensorsdata.horizon.v1.AddSubscriptionApplicationRequest
        grpcServiceBase: com.sensorsdata.horizon.v1.DataSubscriptionServiceGrpc.DataSubscriptionServiceImplBase
        internalDesc: classes in template for grpc service dynamic invoking
        isClientStreaming: false
      x-codegen-request-body-name: AddSubscriptionApplicationRequest
      tags:
      - Data Subscription
  /data-subscription/application/config/append:
    post:
      description: "补充订阅方的配置信息, 例如绑定一个接收新类型数据的 kafka\n ```\n curl -L -X POST 'http://{host}:8107/api/v3/horizon/v1/data-subscription/application/config/append' \\\n -H 'api-key: {api-key}' \\\n -H 'Content-Type: application/json;charset=UTF-8' \\\n -H 'sensorsdata-project: {project_name}' \\\n -d '{\n     \"application_name\": \"{application_name}\",\n     \"kafka_based_app_config\": {\n         \"detail_kafka_descriptor\": {\n             \"type\": \"CUSTOMIZED_KAFKA\",\n             \"customized_kafka_descriptor\": {\n                 \"bootstrap_servers\": \"{broker_list}\",\n                 \"topic_name\": \"{detail_data_topic_name}\"\n             }\n         }\n     }\n }'\n ```"
      operationId: AppendSubscriptionApplicationConfig
      parameters:
      - description: 全局唯一的密钥，用于验证和授权访问 API 接口
        in: header
        name: api-key
        required: true
        schema:
          type: string
      - description: 项目名, 指定请求所属项目
        in: header
        name: sensorsdata-project
        required: true
        schema:
          type: string
      requestBody:
        content:
          application/json:
            schema:
              $ref: '#/components/schemas/sensorsdata.horizon.v1.AppendSubscriptionApplicationConfigRequest'
        required: false
      responses:
        default:
          content:
            application/json:
              example:
                code: SUCCESS
                data:
                  application:
                    kafka_based_app_config:
                      data_format_type: NESTED_JSON
                      event_kafka_descriptor:
                        customized_kafka_descriptor:
                          bootstrap_servers: broker1:9092,broker2:9092
                          topic_name: shence_data_topic
                        type: CUSTOMIZED_KAFKA
                    application_name: shence
                    application_type: KAFKA_BASED_APP
                request_id: '1'
              schema:
                $ref: '#/components/schemas/sensorsdata.horizon.v1.AppendSubscriptionApplicationConfigResponseHttpApiResult'
          description: sensorsdata.horizon.v1.AppendSubscriptionApplicationConfigResponse
      summary: 补充订阅方配置信息
      x-sd-openapi:
        responseClass: com.sensorsdata.horizon.v1.AppendSubscriptionApplicationConfigResponse
        isServerStreaming: false
        requestClass: com.sensorsdata.horizon.v1.AppendSubscriptionApplicationConfigRequest
        grpcServiceBase: com.sensorsdata.horizon.v1.DataSubscriptionServiceGrpc.DataSubscriptionServiceImplBase
        internalDesc: classes in template for grpc service dynamic invoking
        isClientStreaming: false
      x-codegen-request-body-name: AppendSubscriptionApplicationConfigRequest
      tags:
      - Data Subscription
  /data-subscription/application/get:
    post:
      description: "查询订阅方信息\n ```\n curl -X POST 'http://{host}:8107/api/v3/horizon/v1/data-subscription/application/get \\\n -H 'api-key: {api-key}' \\\n -H 'Content-Type: application/json;charset=UTF-8' \\\n -H 'sensorsdata-project: {project_name}' \\\n -d '{\"application_name\": \"{application_name}\"}'\n ```"
      operationId: GetSubscriptionApplication
      parameters:
      - description: 全局唯一的密钥，用于验证和授权访问 API 接口
        in: header
        name: api-key
        required: true
        schema:
          type: string
      - description: 项目名, 指定请求所属项目
        in: header
        name: sensorsdata-project
        required: true
        schema:
          type: string
      requestBody:
        content:
          application/json:
            schema:
              $ref: '#/components/schemas/sensorsdata.horizon.v1.GetSubscriptionApplicationRequest'
        required: false
      responses:
        default:
          content:
            application/json:
              example:
                code: SUCCESS
                data:
                  application:
                    kafka_based_app_config:
                      data_format_type: NESTED_JSON
                      event_kafka_descriptor:
                        customized_kafka_descriptor:
                          bootstrap_servers: broker1:9092,broker2:9092
                          topic_name: shence_data_topic
                        type: CUSTOMIZED_KAFKA
                    application_name: shence
                    application_type: KAFKA_BASED_APP
                request_id: '1'
              schema:
                $ref: '#/components/schemas/sensorsdata.horizon.v1.GetSubscriptionApplicationResponseHttpApiResult'
          description: sensorsdata.horizon.v1.GetSubscriptionApplicationResponse
      summary: 查询订阅方信息
      x-sd-openapi:
        responseClass: com.sensorsdata.horizon.v1.GetSubscriptionApplicationResponse
        isServerStreaming: false
        requestClass: com.sensorsdata.horizon.v1.GetSubscriptionApplicationRequest
        grpcServiceBase: com.sensorsdata.horizon.v1.DataSubscriptionServiceGrpc.DataSubscriptionServiceImplBase
        internalDesc: classes in template for grpc service dynamic invoking
        isClientStreaming: false
      x-codegen-request-body-name: GetSubscriptionApplicationRequest
      tags:
      - Data Subscription
  /data-subscription/application/delete:
    post:
      description: "删除订阅方，删除之前需先取消该订阅方发起的所有订阅\n ```\n curl -X POST 'http://{host}:8107/api/v3/horizon/v1/data-subscription/application/delete' \\\n -H 'api-key: {api-key}' \\\n -H 'Content-Type: application/json;charset=UTF-8' \\\n -H 'sensorsdata-project: {project_name}' \\\n -d '{\n     \"application_name\":\"{application_name}\"\n }'\n ```"
      operationId: DeleteSubscriptionApplication
      parameters:
      - description: 全局唯一的密钥，用于验证和授权访问 API 接口
        in: header
        name: api-key
        required: true
        schema:
          type: string
      - description: 项目名, 指定请求所属项目
        in: header
        name: sensorsdata-project
        required: true
        schema:
          type: string
      requestBody:
        content:
          application/json:
            schema:
              $ref: '#/components/schemas/sensorsdata.horizon.v1.DeleteSubscriptionApplicationRequest'
        required: false
      responses:
        default:
          content:
            application/json:
              example:
                code: SUCCESS
                data: {}
                request_id: '1'
              schema:
                $ref: '#/components/schemas/sensorsdata.horizon.v1.DeleteSubscriptionApplicationResponseHttpApiResult'
          description: sensorsdata.horizon.v1.DeleteSubscriptionApplicationResponse
      summary: 删除订阅方
      x-sd-openapi:
        responseClass: com.sensorsdata.horizon.v1.DeleteSubscriptionApplicationResponse
        isServerStreaming: false
        requestClass: com.sensorsdata.horizon.v1.DeleteSubscriptionApplicationRequest
        grpcServiceBase: com.sensorsdata.horizon.v1.DataSubscriptionServiceGrpc.DataSubscriptionServiceImplBase
        internalDesc: classes in template for grpc service dynamic invoking
        isClientStreaming: false
      x-codegen-request-body-name: DeleteSubscriptionApplicationRequest
      tags:
      - Data Subscription
  /data-subscription/create:
    post:
      description: "创建数据订阅\n ```\n curl -X POST 'http://{host}:8107/api/v3/horizon/v1/data-subscription/create' \\\n -H 'sensorsdata-project: {project_name}' \\\n -H 'Content-Type: application/json;charset=UTF-8' \\\n -H 'api-key: {api-key}' \\\n -d '{\n     \"subscription\": {\n         \"application\": \"{application_id}\",\n         \"subscriber\": \"{subscriber}\",\n         \"target_type\": \"ENTITY_DATA\",\n         \"entity_data_subscription_config\": {\n             \"entity_name\": \"user\",\n             \"attribute_type\": \"SIMPLE\",\n             \"simple_attribute_config\": {\n                 \"attribute_names\": [\n                     \"name\",\n                     \"gender\",\n                     \"age\"\n                 ]\n             }\n         }\n     }\n }'\n ```"
      operationId: CreateDataSubscription
      parameters:
      - description: 全局唯一的密钥，用于验证和授权访问 API 接口
        in: header
        name: api-key
        required: true
        schema:
          type: string
      - description: 项目名, 指定请求所属项目
        in: header
        name: sensorsdata-project
        required: true
        schema:
          type: string
      requestBody:
        content:
          application/json:
            schema:
              $ref: '#/components/schemas/sensorsdata.horizon.v1.CreateDataSubscriptionRequest'
        required: false
      responses:
        default:
          content:
            application/json:
              example:
                code: SUCCESS
                data:
                  subscriber: sa
                  segment_subscription_config: {}
                  application: shence.org-sep-111.app.sensorsdata.cloud
                  target_type: ENTITY_DATA
                  entity_data_subscription_config:
                    events_attribute_config:
                      filter:
                        index: 10
                        conditions:
                        - function: EQUAL
                          index: 10
                          params:
                          - expression: user.p1/user.p2+user.p3
                            field: '#ResourceId'
                            time_point:
                              relative_time:
                                time_interval: {}
                            variable: $ENTRY_TIME
                            value: {}
                            param_type: FIELD
                        operator: AND
                      attribute_names:
                      - time
                      - order_id
                      - amount
                      event_name: payOrder
                    entity_name: user
                    simple_attribute_config:
                      attribute_names:
                      - name
                      - age
                      - gender
                    details_attribute_config:
                      attribute_names:
                      - product_id
                      - price
                      detail_name: cart
                    attribute_type: EVENTS
                  access_info: {}
                request_id: '1'
              schema:
                $ref: '#/components/schemas/sensorsdata.horizon.v1.DataSubscriptionHttpApiResult'
          description: sensorsdata.horizon.v1.DataSubscription
      summary: 创建数据订阅
      x-sd-openapi:
        responseClass: com.sensorsdata.horizon.v1.DataSubscription
        isServerStreaming: false
        requestClass: com.sensorsdata.horizon.v1.CreateDataSubscriptionRequest
        grpcServiceBase: com.sensorsdata.horizon.v1.DataSubscriptionServiceGrpc.DataSubscriptionServiceImplBase
        internalDesc: classes in template for grpc service dynamic invoking
        isClientStreaming: false
      x-codegen-request-body-name: CreateDataSubscriptionRequest
      tags:
      - Data Subscription
  /data-subscription/list:
    get:
      description: "批量查询订阅记录\n 发起请求例子:\n ```\n curl -L -X GET 'http://{host}:8107/api/v3/horizon/v1/data-subscription/list?application={application_id}&subscriber={subscriber}' \\\n -H 'api-key: {api-key}' \\\n -H 'Content-Type: application/json;charset=UTF-8' \\\n -H 'sensorsdata-project: {project_name}'\n ```"
      operationId: ListDataSubscriptions
      parameters:
      - description: 全局唯一的密钥，用于验证和授权访问 API 接口
        in: header
        name: api-key
        required: true
        schema:
          type: string
      - description: 项目名, 指定请求所属项目
        in: header
        name: sensorsdata-project
        required: true
        schema:
          type: string
      - description: 订阅方的唯一标识, 即 application_id
        example: shence.sep-org-111.app.sensorsdata.cloud
        in: query
        name: application
        required: true
        schema:
          type: string
      - description: 订阅方业务标识, 一个 application_id 下可以有多个 subscriber，用户可通过 subscriber 确认订阅记录属于哪个业务方
        example: sa
        in: query
        name: subscriber
        schema:
          type: string
      responses:
        default:
          content:
            application/json:
              example:
                code: SUCCESS
                data:
                  subscriptions:
                  - subscriber: sa
                    segment_subscription_config: {}
                    application: shence.org-sep-111.app.sensorsdata.cloud
                    target_type: ENTITY_DATA
                    entity_data_subscription_config:
                      events_attribute_config:
                        filter:
                          index: 10
                          conditions:
                          - function: EQUAL
                            index: 10
                            params:
                            - expression: user.p1/user.p2+user.p3
                              field: '#ResourceId'
                              time_point:
                                relative_time:
                                  time_interval: {}
                              variable: $ENTRY_TIME
                              value: {}
                              param_type: FIELD
                          operator: AND
                        attribute_names:
                        - time
                        - order_id
                        - amount
                        event_name: payOrder
                      entity_name: user
                      simple_attribute_config:
                        attribute_names:
                        - name
                        - age
                        - gender
                      details_attribute_config:
                        attribute_names:
                        - product_id
                        - price
                        detail_name: cart
                      attribute_type: EVENTS
                    access_info: {}
                request_id: '1'
              schema:
                $ref: '#/components/schemas/sensorsdata.horizon.v1.ListDataSubscriptionsResponseHttpApiResult'
          description: sensorsdata.horizon.v1.ListDataSubscriptionsResponse
      summary: 批量查询订阅记录列表
      x-sd-openapi:
        responseClass: com.sensorsdata.horizon.v1.ListDataSubscriptionsResponse
        isServerStreaming: false
        requestClass: com.sensorsdata.horizon.v1.ListDataSubscriptionsRequest
        grpcServiceBase: com.sensorsdata.horizon.v1.DataSubscriptionServiceGrpc.DataSubscriptionServiceImplBase
        internalDesc: classes in template for grpc service dynamic invoking
        isClientStreaming: false
      tags:
      - Data Subscription
  /data-subscription/batch-delete:
    post:
      description: "批量取消订阅\n ```\n curl -X POST 'http://{host}:8107/api/v3/horizon/v1/data-subscription/batch-delete' \\\n -H 'api-key: {api-key}' \\\n -H 'Content-Type: application/json;charset=UTF-8' \\\n -H 'sensorsdata-project: {project_name}' \\\n -d '{\n    \"application\":\"{application_id}\",\n    \"subscriber\":\"{subscriber}\",\n    \"subscription_ids\":[{subscription_id}]\n }'\n ```"
      operationId: BatchDeleteDataSubscriptions
      parameters:
      - description: 全局唯一的密钥，用于验证和授权访问 API 接口
        in: header
        name: api-key
        required: true
        schema:
          type: string
      - description: 项目名, 指定请求所属项目
        in: header
        name: sensorsdata-project
        required: true
        schema:
          type: string
      requestBody:
        content:
          application/json:
            schema:
              $ref: '#/components/schemas/sensorsdata.horizon.v1.BatchDeleteDataSubscriptionsRequest'
        required: false
      responses:
        default:
          content:
            application/json:
              example:
                code: SUCCESS
                data: {}
                request_id: '1'
              schema:
                $ref: '#/components/schemas/sensorsdata.common.HttpApiResult'
          description: ''
      summary: 批量取消订阅
      x-sd-openapi:
        responseClass: com.google.protobuf.Empty
        isServerStreaming: false
        requestClass: com.sensorsdata.horizon.v1.BatchDeleteDataSubscriptionsRequest
        grpcServiceBase: com.sensorsdata.horizon.v1.DataSubscriptionServiceGrpc.DataSubscriptionServiceImplBase
        internalDesc: classes in template for grpc service dynamic invoking
        isClientStreaming: false
      x-codegen-request-body-name: BatchDeleteDataSubscriptionsRequest
      tags:
      - Data Subscription
components:
  schemas:
    sensorsdata.horizon.v1.DeleteSubscriptionApplicationRequest:
      description: ''
      properties:
        application_id:
          description: 订阅方的唯一标识
          example: shence.sep-org-111.app.sensorsdata.cloud
          type: string
        application_name:
          description: "订阅方业务唯一标识, 与 application_id 其一必填\n 如果未指定 application_id, 会使用 {application_name}.{organization_id}.app.sensorsdata.cloud 拼接成 application_id"
          example: shence
          type: string
      title: DeleteSubscriptionApplicationRequest
      type: object
    sensorsdata.horizon.v1.CreateDataSubscriptionRequest:
      description: ''
      properties:
        subscription:
          $ref: '#/components/schemas/sensorsdata.horizon.v1.DataSubscription'
      required:
      - subscription
      title: CreateDataSubscriptionRequest
      type: object
    sensorsdata.horizon.v1.AddSubscriptionApplicationResponse:
      description: ''
      properties:
        application:
          $ref: '#/components/schemas/sensorsdata.horizon.v1.SubscriptionApplication'
      title: AddSubscriptionApplicationResponse
      type: object
    sensorsdata.common.Literal:
      description: ''
      properties:
        data_type:
          description: ''
          enum:
          - DATA_TYPE_UNSPECIFIED
          - BOOL
          - INT
          - NUMBER
          - STRING
          - LIST
          - DATETIME
          - DATE
          - BIGINT
          - DECIMAL
          type: string
        bool_value:
          description: ''
          type: boolean
        int_value:
          description: ''
          format: int64
          type: integer
        number_value:
          description: ''
          format: double
          type: number
        string_value:
          description: ''
          type: string
        list_value:
          description: ''
          items:
            type: string
          type: array
        datetime_value:
          description: ''
          format: date-time
          type: string
        date_value:
          description: ''
          type: string
        bigint_value:
          description: ''
          format: int64
          type: integer
        decimal_value:
          description: ''
          type: string
      title: Literal
      type: object
    sensorsdata.common.FilterCondition:
      description: 单个过滤条件
      properties:
        function:
          description: 过滤条件的判断函数
          enum:
          - PREDICATE_FUNCTION_TYPE_UNSPECIFIED
          - IS_SET
          - IS_NOT_SET
          - EQUAL
          - NOT_EQUAL
          - IN
          - NOT_IN
          - LESS
          - LESS_EQUAL
          - GREATER
          - GREATER_EQUAL
          - BETWEEN
          - RIGHT_OPEN_BETWEEN
          - HASH_BETWEEN
          - LEFT_OPEN_BETWEEN
          - OPEN_BETWEEN
          - IS_TRUE
          - IS_FALSE
          - CONTAIN
          - NOT_CONTAIN
          - IS_EMPTY
          - IS_NOT_EMPTY
          - RLIKE
          - NOT_RLIKE
          - INCLUDE
          - NOT_INCLUDE
          - ABSOLUTE_BETWEEN
          - RELATIVE_WITHIN
          - RELATIVE_BETWEEN
          - RELATIVE_EVENT_TIME
          - RELATIVE_BEFORE
          - INTERSECTS
          - NOT_INTERSECTS
          - SUBSET_OF
          - NOT_SUBSET_OF
          - SUPERSET_OF
          - NOT_SUPERSET_OF
          example: EQUAL
          type: string
        params:
          description: 函数的参数
          items:
            $ref: '#/components/schemas/sensorsdata.common.PredicateFunctionParam'
          type: array
        index:
          description: 当前筛选条件所处的位置下标，主要为了保证前端展示顺序的稳定
          example: 10
          format: int32
          type: integer
      title: FilterCondition
      type: object
    sensorsdata.horizon.v1.ListDataSubscriptionsResponseHttpApiResult:
      properties:
        code:
          type: string
        message:
          type: string
        request_id:
          type: string
        data:
          $ref: '#/components/schemas/sensorsdata.horizon.v1.ListDataSubscriptionsResponse'
        error_info:
          $ref: '#/components/schemas/sensorsdata.common.ErrorInfo'
      title: sensorsdata.horizon.v1.ListDataSubscriptionsResponseHttpApiResult
      type: object
    sensorsdata.horizon.v1.KafkaTopicDescriptor:
      description: ''
      properties:
        bootstrap_servers:
          description: kafka 的 broker 地址, 多个地址之间使用英文逗号分隔
          example: broker1:9092,broker2:9092
          type: string
        topic_name:
          description: kafka 的 topic 名称
          example: shence_data_topic
          type: string
        kafka_properties:
          additionalProperties:
            description: ''
            type: string
          description: kafka 相关参数，如 sasl 认证信息.
          example:
            security.protocol: SASL_SSL
            sasl.username: admin
            sasl.mechanism: SCRAM-SHA-256
            sasl.password: pwd123
          type: object
        cert_file_token:
          description: 如果 kafka 开启了认证, 使用 uploadFile 接口上传证书文件后返回的 file_token
          example: 84e1f867bf4942ca9b7e985d197facc2
          type: string
      title: KafkaTopicDescriptor
      type: object
    sensorsdata.common.ErrorInfo:
      properties:
        code:
          description: 具体的错误码
          example: XX-D-F-2-1
          type: string
        description:
          description: 错误描述
          example: 前端参数校验异常,PARAMETER_FORMAT_ERROR(quantiles=[10, -90] is not include [0, 100])
          type: string
        system_response:
          description: 致错的可能原因列表
          example: 系统终止了查询处理
          type: string
        error_causes:
          items:
            $ref: '#/components/schemas/sensorsdata.common.ErrorCause'
          type: array
        context:
          $ref: '#/components/schemas/sensorsdata.common.ErrorContext'
      title: ErrorInfo
      type: object
    sensorsdata.horizon.v1.KafkaDescriptor:
      description: ''
      properties:
        type:
          description: "kafka 的类型\n '''\n CUSTOMIZED_KAFKA: 业务方自定义的 kafka\n '''"
          enum:
          - CUSTOMIZED_KAFKA
          example: CUSTOMIZED_KAFKA
          type: string
        customized_kafka_descriptor:
          $ref: '#/components/schemas/sensorsdata.horizon.v1.KafkaTopicDescriptor'
      title: KafkaDescriptor
      type: object
    sensorsdata.horizon.v1.GetSubscriptionApplicationResponseHttpApiResult:
      properties:
        code:
          type: string
        message:
          type: string
        request_id:
          type: string
        data:
          $ref: '#/components/schemas/sensorsdata.horizon.v1.GetSubscriptionApplicationResponse'
        error_info:
          $ref: '#/components/schemas/sensorsdata.common.ErrorInfo'
      title: sensorsdata.horizon.v1.GetSubscriptionApplicationResponseHttpApiResult
      type: object
    sensorsdata.horizon.v1.ListDataSubscriptionsResponse:
      description: ''
      properties:
        subscriptions:
          description: 订阅记录列表
          items:
            $ref: '#/components/schemas/sensorsdata.horizon.v1.DataSubscription'
          type: array
      title: ListDataSubscriptionsResponse
      type: object
    sensorsdata.common.ErrorContext:
      description: 发生错误时，系统快照信息
      properties:
        origin_stack:
          description: 上游异常的 stack，由系统截获
          type: string
        origin_cause:
          description: 上游异常的 cause by，由系统截获
          type: string
        origin_code:
          description: 上游异常的错误简码
          type: string
        origin_complete_code:
          description: 上游异常的完整错误码
          type: string
        error_extend_desc:
          description: 本次异常的辅助说明，可传入
          type: string
      title: ErrorContext
      type: object
    sensorsdata.horizon.v1.EntityDataSubscriptionConfig.EventsAttributeSubscriptionConfig:
      description: ''
      properties:
        event_name:
          description: 事件名
          example: payOrder
          type: string
        attribute_names:
          description: 事件属性名
          example: '["time", "order_id", "amount"]'
          items:
            type: string
          type: array
        filter:
          $ref: '#/components/schemas/sensorsdata.common.CompoundFilterCondition'
      title: EventsAttributeSubscriptionConfig
      type: object
    sensorsdata.horizon.v1.AppendSubscriptionApplicationConfigRequest:
      description: ''
      properties:
        application_id:
          description: 订阅方的唯一标识
          example: shence.sep-org-111.app.sensorsdata.cloud
          type: string
        application_name:
          description: "订阅方业务唯一标识, 与 application_id 其一必填\n 如果未指定 application_id, 会使用 {application_name}.{organization_id}.app.sensorsdata.cloud 拼接成 application_id"
          example: shence
          type: string
        kafka_based_app_config:
          $ref: '#/components/schemas/sensorsdata.horizon.v1.KafkaBasedAppConfig'
      title: AppendSubscriptionApplicationConfigRequest
      type: object
    sensorsdata.common.ErrorCause:
      properties:
        error_cause:
          description: 致错原因1
          example: 参数异常1
          type: string
        action_suggestion:
          description: 操作建议，针对该原因，建议的解决方式
          example: 检测入参的数据类型1
          type: string
      title: ErrorCause
      type: object
    sensorsdata.common.PredicateFunctionParam:
      description: "```\n 函数的参数，有几种可能\n 1. 一个 field, 如 events.$Anything.$city\n 2. 一个 Literal 的常量\n 3. 一个变量, 如 $ENTRY_TIME, 需要在执行上下文里进行替换\n 4. 一个 TimePoint, 代表一个相对或绝对的时间点, 用于时间类型的条件\n 5. 一个 expression user.p1/user.p2+user.p3\n ```"
      properties:
        param_type:
          description: 函数的参数类型
          enum:
          - FUNCTION_PARAM_TYPE_UNSPECIFIED
          - FIELD
          - VALUE
          - VARIABLE
          - TIME_POINT
          - EXPRESSION
          example: FIELD
          type: string
        field:
          description: 字段名
          example: '#ResourceId'
          type: string
        value:
          $ref: '#/components/schemas/sensorsdata.common.Literal'
        variable:
          description: 变量，需要在执行上下文里进行替换
          example: $ENTRY_TIME
          type: string
        time_point:
          $ref: '#/components/schemas/sensorsdata.common.TimePoint'
        expression:
          description: 自定义表达式
          example: user.p1/user.p2+user.p3
          type: string
      title: PredicateFunctionParam
      type: object
    sensorsdata.horizon.v1.BatchDeleteDataSubscriptionsRequest:
      description: ''
      properties:
        application:
          description: 订阅方的唯一标识, 即 application_id
          example: shence.sep-org-111.app.sensorsdata.cloud
          type: string
        subscriber:
          description: 订阅方业务标识, 一个 application_id 下可以有多个 subscriber，用户可通过 subscriber 确认订阅记录属于哪个业务方
          example: sa
          type: string
        subscription_ids:
          description: 要取消订阅的记录 

# --- truncated at 32 KB (43 KB total) ---
# Full source: https://raw.githubusercontent.com/api-evangelist/sensors-data/refs/heads/main/openapi/sensors-data-data-subscription-api-openapi.yml