홈>
아파치 빔 애플리케이션은 JSON 배열로 메시지를 수신하지만 각 행을 BigQuery 테이블에 삽입합니다. ApacheBeam에서이 사용 사례를 어떻게 지원할 수 있습니까? 각 행을 분할하여 하나씩 테이블에 삽입 할 수 있습니까?
JSON 메시지 예 :
[
{"id": 1, "name": "post1", "price": 10},
{"id": 2, "name": "post2", "price": 20},
{"id": 3, "name": "post3", "price": 30}
]
BigQuery 테이블 스키마 :
[
{
"mode": "REQUIRED",
"name": "id",
"type": "INT64"
},
{
"mode": "REQUIRED",
"name": "name",
"type": "STRING"
},
{
"mode": "REQUIRED",
"name": "price",
"type": "INT64"
}
]
-
답변 # 1
관련 자료
- c++ - 해시 테이블에 배열 요소 삽입
- reactjs - react-dnd beautiful을 사용하여 어떻게 새 항목을 배열에 삽입합니까, 아니면 작동하지 않습니까?
- Python - 파이썬 - 프로그래밍 방식으로 json을 google bigquery 테이블에로드
- mysql - 테이블의 한 열에있는 문자열 배열의 데이터를 테이블의 다른 열에있는 JSON 데이터와 어떻게 비교할 수 있습니까?
- java - 모든 배열 요소의 정사각형을 0 미만으로 만들고 해당 음수 요소의 다음 위치에 삽입합니다
- javascript - 개체의 원래 배열에서 일부 날짜가 누락 된 경우 날짜를 삽입하는 방법
- javascript - 표 헤더별로 클릭시 배열을 정렬하는 방법
- google cloud platform - 대상 테이블이 매일 파티션되지 않은 경우 Bigquery 데이터 전송 실패
- javascript - 책의 배열에 책 개체 삽입
- ADT 유형의 속성이 하나있는 DB 테이블에 삽입하려면 어떻게해야합니까? Oracle Live SQL 사용
- sql - 긴 텍스트 열이있는 JSON 배열로 테이블 변환
- Flutter 중첩 된 JSON 배열을 다른 SQLite 테이블에 삽입하는 방법
- 파이썬의 특정 인덱스에서 다른 배열에 부동 소수점 배열을 삽입하는 방법
- HTML 테이블에 표시하기 위해 JavaScript 배열 조작
- sql - 큰 쿼리 테이블에서 INSERT와 함께 CASE 문을 사용할 수 있습니까?
- sql - 두 테이블에서 구별되는 선택을 포함하여 다중 선택으로 테이블에 삽입
- c++ - std - : move_backwards를 사용하여 지정된 위치에 배열을 삽입하는 방법
- Python을 사용하여 텍스트 파일의 데이터를 SQL Server 테이블에 삽입하는 방법은 무엇입니까?
- C에서 문자열의 동적 배열에 삽입
- postgresql - 임시 테이블을 만들고 삽입 한 다음 pgsql 함수 내에서 선택합니다
트렌드
- OpenCv의 폴더에서 여러 이미지 읽기 (python)
- 파이썬 셀레늄 모든 "href"속성 가져 오기
- git commit - 자식 - 로컬 커밋 된 파일에 대한 변경을 취소하는 방법
- html - 자바 스크립트 - 클릭 후 변경 버튼 텍스트 변경
- JSP에 대한 클래스를 컴파일 할 수 없습니다
- javascript - 현재 URL에서 특정 div 만 새로 고침/새로 고침
- jquery - JavaScript로 현재 세션 값을 얻으시겠습니까?
- javascript - swiperjs에서 정지, 재생 버튼 추가
- vue.js - axios를 사용하여 서버에 이미지를 업로드하는 방법
- python - 문자열에서 특정 문자 제거
여기 내 해결책이 있습니다. JSON 문자열을 List로 한 번 변환 한 다음 c.output을 하나씩 출력합니다. 내 코드는 스칼라에 있지만 Java에서도 같은 일을 할 수 있습니다.