| | |
|---|
| | | def _check_response(self, response: httpx.Response): |
|---|
| | | """检查响应并处理错误""" |
|---|
| | | if response.status_code not in [200, 201]: |
|---|
| | | raise Exception(f"Failed to fetch data from API: {response.text}") |
|---|
| | | # raise Exception(f"Failed to fetch data from API: {response.status_code}") |
|---|
| | | logger.error(f"Failed to fetch data from API:") |
|---|
| | | logger.error(response.status_code) |
|---|
| | | response_data = response.json() |
|---|
| | | return response_data |
|---|
| | | |
|---|
| | |
|---|
| | | answer = json.loads(decoded_line) |
|---|
| | | yield answer |
|---|
| | | except GeneratorExit as e: |
|---|
| | | logger.error("------------except GeneratorExit as e:---------------------") |
|---|
| | | logger.error(e) |
|---|
| | | print(e) |
|---|
| | | yield {"message": "内部错误", "type": "close"} |
|---|
| | | finally: |
|---|
