如何将RTMP url的查询部分发送到RTMP服务器

import rtmpy

def send_query_part_to_rtmp_server(rtmp_url):
    # 解析URL
    url = rtmpy.URL.parse(rtmp_url)

    # 获取查询部分
    query_part = url.query_string

    # 建立RTMP连接
    connection = rtmpy.RTMPConnection(url.protocol, url.host)

    @connection.on('connect')
    def on_connect():
        # 连接成功后发送查询部分
        connection.create_stream()
        connection.publish(query_part)

    # 连接到RTMP服务器
    connection.connect()

# 调用函数，发送查询部分到RTMP服务器
rtmp_url = 'rtmp://example.com/app/stream?query=part'
send_query_part_to_rtmp_server(rtmp_url)