小编Ана*_*ева的帖子

我不明白如何使用交叉联接连接两个表。早些时候，在 sqlalchemy 版本 1.1.4 中，我这样做：

A = Table1.sa 
B = Table2.sa
my_query = A.query().join(B, literal(True))

但更新到 1.3 版本后，出现异常：

sqlalchemy.exc.InvalidRequestError：无法确定从哪个 FROM 子句加入，有多个 FROM 可以加入到该实体。尝试添加显式 ON 子句以帮助解决歧义。

我明白这意味着我必须做这样的事情：

my_query = A.query().join(B, A.fireign_key_id = B.id)

但是表A没有表B的外键。

如何使用交叉连接而不使用外键连接两个表？谢谢。

这是我的代码，它使用kafka-python.

now = datetime.now()
month_ago = now - relativedelta(month=1)
topic = 'some_topic_name'
consumer = KafkaConsumer(topic, bootstrap_servers=PROD_KAFKA_SERVER,
                         security_protocol=PROTOCOL,
                         group_id=GROUP_ID,
                         enable_auto_commit=False,
                         sasl_mechanism=SASL_MECHANISM, sasl_plain_username=SASL_USERNAME,
                         sasl_plain_password=SASL_PASSWORD)


for msg in consumer:
    print(msg)

我想从循环之间now和month_ago循环中的主题中获取结果。我怎样才能做到这一点？

谢谢你的帮助！