小编mif*_*042的帖子

我在一对一映射中设置了两个实体，如下所示，并且我尝试在存储库中查询连接列，如下所示：

@Entity
@Table(name = "a")
@AllArgsConstructor
@NoArgsConstructor
@Data
@EqualsAndHashCode(callSuper=false)
public class A extends Auditable {

    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;

    @Column(unique = true)
    @Size(min = 1, max = 100)
    private String name;
}


@Entity
@Table(name = "b")
@AllArgsConstructor
@NoArgsConstructor
@Data
@EqualsAndHashCode(callSuper=false)
public class B extends Auditable {

    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;

    @Column
    @Size(min = 1, max = 100)
    private String name;

    @OneToOne
    @JoinColumn(name="aId", referencedColumnName = "aId")
    private A aId;

}

在我的中BRepository.java，我正在尝试这样做：

@Component
public …

我正在尝试使用 FastAPI 设置一个应用程序，但不断收到此错误，我无法理解。我的main.py文件如下：

from fastapi import FastAPI
from app.routers import test

app = FastAPI()
app.include_router(test, prefix="/api/v1/test")

在我的routers/test.py文件中我有：

from fastapi import APIRouter, File, UploadFile
import app.schemas.myschema as my_schema

router = APIRouter()
Response = my_schema.Response


@router.get("/", response_model=Response)
def process(file: UploadFile = File(...)):
    # Do work

但我不断收到以下错误：

文件“/Users/Desktop/test-service/venv/lib/python3.8/site-packages/fastapi/routing.py”，第566行，在router.routes中的router的include_router中：AttributeError：模块'app.routers。 test' 没有属性 'routes' python-BaseException

我无法理解这一点，因为我可以在此处的示例应用程序中看到类似的操作。

我正在使用 python-kafka 来收听 kafka 主题并使用该记录。我想让它无限轮询而不退出。这是我的代码如下：

def test():
    consumer = KafkaConsumer('abc', 'localhost:9092', auto_offset_reset='earliest')
    for msg in consumer:
        print(msg.value)

这段代码只是读取数据，直接退出。有没有办法即使没有推送消息也可以继续收听主题？

任何持续监控该主题的相关示例对我来说也很棒。