创建 RabbitMQSource¶

本主题介绍如何创建 RabbitMQSource。

先决条件¶

您已安装 Knative Eventing
您已安装 CertManager v1.5.4 - 与 RabbitMQ 消息拓扑操作员最轻松的集成
您已安装 RabbitMQ 消息拓扑操作员 - 我们建议您使用最新版本以及 CertManager
一个正常运行的 RabbitMQ 实例，我们建议您使用 RabbitMQ 集群操作员创建一个。有关配置 RabbitmqCluster CRD 的更多信息，请参见 RabbitMQ 网站

安装 RabbitMQ 控制器¶

通过运行以下命令来安装 RabbitMQSource 控制器

kubectl apply -f https://github.com/knative-extensions/eventing-rabbitmq/releases/download/knative-v1.16.0/rabbitmq-source.yaml

验证 rabbitmq-controller-manager 和 rabbitmq-webhook 是否正在运行

kubectl get deployments.apps -n knative-sources

示例输出

NAME                           READY   UP-TO-DATE   AVAILABLE   AGE
rabbitmq-controller-manager     1/1     1            1           3s
rabbitmq-webhook                1/1     1            1           4s

创建服务¶

创建 event-display 服务作为 YAML 文件

apiVersion: serving.knative.dev/v1
kind: Service
metadata:
  name: event-display
  namespace: default
spec:
  template:
    spec:
      containers:
        - # This corresponds to
          # https://github.com/knative/eventing/tree/main/cmd/event_display/main.go
          image: gcr.io/knative-releases/knative.dev/eventing/cmd/event_display

通过运行以下命令应用 YAML 文件
```
kubectl apply -f <filename>.yaml
```
其中 <filename> 是您在上一步骤中创建的文件的名称。

示例输出
```
service.serving.knative.dev/event-display created
```

确保服务 Pod 正在运行，方法是运行以下命令

kubectl get pods

Pod 名称以 event-display 为前缀

NAME                                            READY     STATUS    RESTARTS   AGE
event-display-00001-deployment-5d5df6c7-gv2j4   2/2       Running   0          72s

创建 RabbitMQSource 对象¶

使用以下模板创建一个 YAML 文件

apiVersion: sources.knative.dev/v1alpha1
kind: RabbitmqSource
metadata:
  name: <source-name>
spec:
  rabbitmqClusterReference:
    # Configure name if a RabbitMQ Cluster Operator is being used.
    name: <cluster-name>
    # Configure connectionSecret if an external RabbitMQ cluster is being used.
    connectionSecret:
      name: rabbitmq-secret-credentials
  rabbitmqResourcesConfig:
    parallelism: 10
    exchangeName: "eventing-rabbitmq-source"
    queueName: "eventing-rabbitmq-source"
  delivery:
    retry: 5
    backoffPolicy: "linear"
    backoffDelay: "PT1S"
  sink:
    ref:
      apiVersion: serving.knative.dev/v1
      kind: Service
      name: event-display

其中

<source-name> 是您要为 RabbitMQSource 对象指定的名称。
<cluster-name> 是您之前创建的 RabbitMQ 集群的名称。

注意

您不能同时设置 name 和 connectionSecret，因为 name 用于在与 Source 相同的集群中运行的 RabbitMQ 集群操作员实例，而 connectionSecret 用于外部 RabbitMQ 服务器。

通过运行以下命令应用 YAML 文件
```
kubectl apply -f <filename>
```
其中 <filename> 是您在上一步骤中创建的文件的名称。

验证¶

检查 event-display 服务以查看它是否正在接收事件。源可能需要一段时间才能开始将事件发送到 Sink。

  kubectl -l='serving.knative.dev/service=event-display' logs -c user-container
  ☁️  cloudevents.Event
  Context Attributes,
    specversion: 1.0
    type: dev.knative.rabbitmq.event
    source: /apis/v1/namespaces/default/rabbitmqsources/<source-name>
    subject: f147099d-c64d-41f7-b8eb-a2e53b228349
    id: f147099d-c64d-41f7-b8eb-a2e53b228349
    time: 2021-12-16T20:11:39.052276498Z
    datacontenttype: application/json
  Data,
    {
      ...
      Random Data
      ...
    }

清理¶

删除 RabbitMQSource

kubectl delete -f <source-yaml-filename>

删除 RabbitMQ 凭据密钥

kubectl delete -f <secret-yaml-filename>

删除事件显示服务

kubectl delete -f <service-yaml-filename>

其他信息¶

有关更多示例，请访问 eventing-rabbitmq Github 存储库示例目录
要报告错误或请求功能，请在 eventing-rabbitmq Github 存储库中打开问题。